This closes #672
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/d871dfe6 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/d871dfe6 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/d871dfe6 Branch: refs/heads/master Commit: d871dfe6225dc4f3c08d9fb9c41069b0849eff2f Parents: c13a976 a741642 Author: Clebert Suconic <[email protected]> Authored: Wed Aug 3 18:39:58 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Wed Aug 3 18:39:58 2016 -0400 ---------------------------------------------------------------------- .../client/impl/ClientSessionFactoryImpl.java | 15 +++++ .../core/client/impl/ClientSessionImpl.java | 5 ++ .../core/client/impl/ClientSessionInternal.java | 3 + .../core/impl/ActiveMQSessionContext.java | 21 +++++++ .../core/protocol/core/impl/PacketImpl.java | 2 + .../core/impl/RemotingConnectionImpl.java | 12 ++++ .../DisconnectConsumerWithKillMessage.java | 60 ++++++++++++++++++++ .../spi/core/protocol/RemotingConnection.java | 5 ++ .../main/resources/activemq-version.properties | 2 +- .../ActiveMQProtonRemotingConnection.java | 6 ++ .../core/protocol/mqtt/MQTTConnection.java | 6 ++ .../protocol/openwire/OpenWireConnection.java | 5 ++ .../core/protocol/stomp/StompConnection.java | 5 ++ .../artemis/core/server/impl/QueueImpl.java | 5 +- pom.xml | 2 +- .../integration/client/SlowConsumerTest.java | 38 +++++++++++++ 16 files changed, 189 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
