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 2017/12/19 20:09:08 UTC
[4/4] activemq-artemis git commit: This closes #1722
This closes #1722
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/386f0903
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/386f0903
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/386f0903
Branch: refs/heads/master
Commit: 386f0903723b7f6462dcf475e578f3c09e3d2273
Parents: fb34214 8f5b7a1
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue Dec 19 15:05:15 2017 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Dec 19 15:05:15 2017 -0500
----------------------------------------------------------------------
.../core/client/SendAcknowledgementHandler.java | 7 ++
.../client/ActiveMQClientMessageBundle.java | 3 +
.../artemis/core/protocol/core/Channel.java | 3 +
.../protocol/core/CoreRemotingConnection.java | 5 +
.../artemis/core/protocol/core/Packet.java | 8 ++
.../core/protocol/core/ResponseHandler.java | 30 +++++
.../core/impl/ActiveMQSessionContext.java | 89 ++++++++++----
.../core/protocol/core/impl/ChannelImpl.java | 64 +++++++++-
.../core/protocol/core/impl/PacketDecoder.java | 26 +++-
.../core/protocol/core/impl/PacketImpl.java | 33 +++++
.../core/protocol/core/impl/ResponseCache.java | 61 ++++++++++
.../impl/wireformat/CreateAddressMessage.java | 1 +
.../impl/wireformat/CreateQueueMessage.java | 1 +
.../wireformat/CreateSharedQueueMessage.java | 1 +
.../wireformat/ExceptionResponseMessage.java | 120 +++++++++++++++++++
.../wireformat/SessionAcknowledgeMessage.java | 1 +
.../SessionCreateConsumerMessage.java | 1 +
.../SessionIndividualAcknowledgeMessage.java | 1 +
.../SessionSendContinuationMessage.java | 31 ++++-
.../SessionSendContinuationMessage_V2.java | 120 +++++++++++++++++++
.../impl/wireformat/SessionSendMessage.java | 20 +++-
.../impl/wireformat/SessionSendMessage_V2.java | 113 +++++++++++++++++
.../impl/wireformat/SuccessResponseMessage.java | 93 ++++++++++++++
.../main/resources/activemq-version.properties | 2 +-
.../jms/client/ActiveMQMessageProducer.java | 30 +++++
.../core/protocol/ServerPacketDecoder.java | 10 ++
.../core/ServerSessionPacketHandler.java | 94 ++++++++++-----
pom.xml | 2 +-
.../tests/compatibility/SendAckTest.java | 2 +
.../cluster/util/BackupSyncDelay.java | 6 +
.../artemis/jms/tests/SecurityTest.java | 82 ++++++++++++-
tests/jms-tests/src/test/resources/broker.xml | 10 ++
32 files changed, 1006 insertions(+), 64 deletions(-)
----------------------------------------------------------------------