Repository: activemq Updated Branches: refs/heads/master c1157fe1f -> 338a74dfa
https://issues.apache.org/jira/browse/AMQ-6470 - Remove unused ControlCommand handling in client Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/338a74df Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/338a74df Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/338a74df Branch: refs/heads/master Commit: 338a74dfa42a7b19d39adecacfa5f626a050e807 Parents: c1157fe Author: Dejan Bosanac <de...@nighttale.net> Authored: Tue Oct 18 12:04:11 2016 +0200 Committer: Dejan Bosanac <de...@nighttale.net> Committed: Tue Oct 18 12:04:11 2016 +0200 ---------------------------------------------------------------------- .../org/apache/activemq/ActiveMQConnection.java | 20 -------------------- 1 file changed, 20 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/338a74df/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java ---------------------------------------------------------------------- diff --git a/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java index 1f360cb..8e6c157 100755 --- a/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java +++ b/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java @@ -1873,7 +1873,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon @Override public Response processControlCommand(ControlCommand command) throws Exception { - onControlCommand(command); return null; } @@ -2221,25 +2220,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon } } - protected void onControlCommand(ControlCommand command) { - String text = command.getCommand(); - if (text != null) { - if ("shutdown".equals(text)) { - LOG.info("JVM told to shutdown"); - System.exit(0); - } - - // TODO Should we handle the "close" case? - // if (false && "close".equals(text)){ - // LOG.error("Broker " + getBrokerInfo() + "shutdown connection"); - // try { - // close(); - // } catch (JMSException e) { - // } - // } - } - } - protected void onConnectionControl(ConnectionControl command) { if (command.isFaultTolerant()) { this.optimizeAcknowledge = false;
