activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-6470 - Remove unused ControlCommand handling in client
Date Tue, 18 Oct 2016 10:04:22 GMT
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 <dejan@nighttale.net>
Authored: Tue Oct 18 12:04:11 2016 +0200
Committer: Dejan Bosanac <dejan@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;


Mime
View raw message