You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/08/03 22:40:19 UTC

[2/2] activemq-artemis git commit: This closes #672

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 <cl...@apache.org>
Authored: Wed Aug 3 18:39:58 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
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(-)
----------------------------------------------------------------------