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

ACTIVEMQ-106 Drop ConnectionControl Packet

This commit is contained in:
Martyn Taylor 2015-05-15 11:57:10 +01:00
parent 042a8f556a
commit 2de3bfa9f1
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/AMQConnectorImpl.java
View File

@ -84,7 +84,7 @@ public class AMQConnectorImpl implements AMQConnector
public boolean isAllowLinkStealing() public boolean isAllowLinkStealing()
{ {
// TODO Auto-generated method stub // TODO Auto-generated method stub
return false; return true;
} }
@Override @Override

7
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManager.java
View File

@ -232,6 +232,13 @@ public class OpenWireProtocolManager implements ProtocolManager<Interceptor>
{ {
case CommandTypes.CONNECTION_INFO: case CommandTypes.CONNECTION_INFO:
break; break;
case CommandTypes.CONNECTION_CONTROL:
/** The ConnectionControl packet sent from client informs the broker that is capable of supporting dynamic
* failover and load balancing. These features are not yet implemented for Artemis OpenWire. Instead we
* simply drop the packet. See: ACTIVEMQ6-108 */
break;
case CommandTypes.CONSUMER_CONTROL:
break;
default: default:
throw new IllegalStateException("Cannot handle command: " + command); throw new IllegalStateException("Cannot handle command: " + command);
} }