Repository: incubator-ignite Updated Branches: refs/heads/ignite-1121 95fb321f6 -> c025772b1
# IGNITE-1121 Introduce constant: RECONNECT_INTERVAL Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c025772b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c025772b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c025772b Branch: refs/heads/ignite-1121 Commit: c025772b1c6112934130b017469a03f6f917092a Parents: 95fb321 Author: sevdokimov <sergey.evdoki...@jetbrains.com> Authored: Wed Jul 22 17:12:28 2015 +0300 Committer: sevdokimov <sergey.evdoki...@jetbrains.com> Committed: Wed Jul 22 17:12:28 2015 +0300 ---------------------------------------------------------------------- .../src/main/java/org/apache/ignite/agent/AgentLauncher.java | 7 ++++++- .../src/main/java/org/apache/ignite/agent/AgentSocket.java | 3 ++- 2 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c025772b/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentLauncher.java ---------------------------------------------------------------------- diff --git a/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentLauncher.java b/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentLauncher.java index a4c24e5..47b0187 100644 --- a/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentLauncher.java +++ b/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentLauncher.java @@ -28,7 +28,12 @@ import java.net.*; * */ public class AgentLauncher { + /** */ + private static final int RECONNECT_INTERVAL = 3000; + /** + * @param args Args. + */ protected static AgentConfiguration getConfiguration(String[] args) throws IOException { AgentConfiguration cfg = new AgentConfiguration(); @@ -92,7 +97,7 @@ public class AgentLauncher { agentSock.waitForClose(); - Thread.sleep(3000); + Thread.sleep(RECONNECT_INTERVAL); } } finally { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c025772b/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentSocket.java ---------------------------------------------------------------------- diff --git a/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentSocket.java b/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentSocket.java index 01b660f..cee61e4 100644 --- a/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentSocket.java +++ b/modules/control-center-agent/src/main/java/org/apache/ignite/agent/AgentSocket.java @@ -17,6 +17,7 @@ package org.apache.ignite.agent; +import org.apache.http.*; import org.apache.ignite.agent.messages.*; import org.eclipse.jetty.websocket.api.*; import org.eclipse.jetty.websocket.api.annotations.*; @@ -115,7 +116,7 @@ public class AgentSocket { catch (Exception e) { restRes = new RestResult(); - restRes.setCode(500); + restRes.setCode(HttpStatus.SC_INTERNAL_SERVER_ERROR); restRes.setMessage(e.getMessage()); }
