Repository: activemq-artemis Updated Branches: refs/heads/master 515a2e064 -> 94be09686
This closes #2187 Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/94be0968 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/94be0968 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/94be0968 Branch: refs/heads/master Commit: 94be096861f1baa12180d8375a60f4bcb1d9792c Parents: 515a2e0 a28b4fb Author: Clebert Suconic <[email protected]> Authored: Thu Sep 27 17:29:18 2018 -0400 Committer: Clebert Suconic <[email protected]> Committed: Thu Sep 27 17:29:18 2018 -0400 ---------------------------------------------------------------------- .../core/client/SendAcknowledgementHandler.java | 9 + .../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 | 71 ++- .../core/protocol/core/impl/ChannelImpl.java | 67 ++- .../core/protocol/core/impl/PacketDecoder.java | 34 +- .../core/protocol/core/impl/PacketImpl.java | 26 +- .../core/protocol/core/impl/ResponseCache.java | 74 +++ .../wireformat/ActiveMQExceptionMessage.java | 2 +- .../wireformat/ActiveMQExceptionMessage_V2.java | 101 ++++ .../impl/wireformat/CreateAddressMessage.java | 1 + .../impl/wireformat/CreateQueueMessage.java | 1 + .../wireformat/CreateSharedQueueMessage.java | 1 + .../impl/wireformat/NullResponseMessage_V2.java | 96 ++++ .../wireformat/SessionAcknowledgeMessage.java | 1 + .../SessionCreateConsumerMessage.java | 1 + .../SessionIndividualAcknowledgeMessage.java | 1 + .../SessionSendContinuationMessage.java | 31 +- .../SessionSendContinuationMessage_V2.java | 122 +++++ .../impl/wireformat/SessionSendMessage.java | 27 +- .../impl/wireformat/SessionSendMessage_V2.java | 104 ++++ .../wireformat/SessionXAResponseMessage.java | 6 +- .../wireformat/SessionXAResponseMessage_V2.java | 102 ++++ .../main/resources/activemq-version.properties | 2 +- .../protocol/core/impl/ChannelImplTest.java | 512 +++++++++++++++++++ .../jms/client/ActiveMQMessageProducer.java | 76 ++- .../core/protocol/ServerPacketDecoder.java | 5 +- .../core/ServerSessionPacketHandler.java | 176 ++++--- pom.xml | 2 +- .../cluster/util/BackupSyncDelay.java | 6 + .../JmsProducerCompletionListenerTest.java | 19 +- .../artemis/jms/tests/SecurityTest.java | 189 ++++++- tests/jms-tests/src/test/resources/broker.xml | 10 + 36 files changed, 1798 insertions(+), 126 deletions(-) ----------------------------------------------------------------------
