https://issues.apache.org/jira/browse/AMQ-6470 - Remove unused Contro…

…lCommand handling in client (cherry picked from commit 338a74d)
apache · Mar 6, 2017 · b8fc78e · b8fc78e
1 parent 2dfe0c7
commit b8fc78e
Showing 1 changed file with 0 additions and 20 deletions.
diff --git 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 void run() {
 
                     @Override
                     public Response processControlCommand(ControlCommand command) throws Exception {
-                        onControlCommand(command);
                         return null;
                     }
 
@@ -2221,25 +2220,6 @@ void send(ActiveMQDestination destination, ActiveMQMessage msg, MessageId messag
         }
     }
 
-    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;