Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-6470 - Remove unused ControlCommand handling in client

This commit is contained in:
Dejan Bosanac 2016-10-18 12:04:11 +02:00
parent c1157fe1f0
commit 338a74dfa4
1 changed files with 0 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -1873,7 +1873,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
@Override @Override
public Response processControlCommand(ControlCommand command) throws Exception { public Response processControlCommand(ControlCommand command) throws Exception {
onControlCommand(command);
return null; 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) { protected void onConnectionControl(ConnectionControl command) {
if (command.isFaultTolerant()) { if (command.isFaultTolerant()) {
this.optimizeAcknowledge = false; this.optimizeAcknowledge = false;