This closes #1102
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/224d7806 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/224d7806 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/224d7806 Branch: refs/heads/master Commit: 224d780622be3f65cef027bd4f84078102d25919 Parents: 861c231 1ef4dcf Author: Timothy Bish <[email protected]> Authored: Fri Mar 17 17:28:23 2017 -0400 Committer: Timothy Bish <[email protected]> Committed: Fri Mar 17 17:28:23 2017 -0400 ---------------------------------------------------------------------- .../amqp/broker/AMQPConnectionCallback.java | 25 ++++-- .../protocol/amqp/broker/AMQPMessage.java | 68 ++++++++------- .../amqp/broker/AMQPSessionCallback.java | 30 +++---- .../amqp/proton/AMQPSessionContext.java | 2 +- .../proton/ProtonServerReceiverContext.java | 4 +- .../amqp/proton/ProtonServerSenderContext.java | 15 +--- .../transaction/ProtonTransactionHandler.java | 78 ++++++++++------- .../protocol/amqp/util/DeliveryUtil.java | 18 +--- .../integration/amqp/AmqpTransactionTest.java | 90 +++++++++++++++++++- 9 files changed, 204 insertions(+), 126 deletions(-) ----------------------------------------------------------------------
