This closes #2064
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/410cb9ee Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/410cb9ee Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/410cb9ee Branch: refs/heads/master Commit: 410cb9ee23f205ebdfb520ecf0699a7ceefd7119 Parents: b60f648 c1cf9ef Author: Clebert Suconic <[email protected]> Authored: Thu May 3 12:10:26 2018 -0400 Committer: Clebert Suconic <[email protected]> Committed: Thu May 3 12:10:26 2018 -0400 ---------------------------------------------------------------------- .../protocol/amqp/broker/AMQPMessage.java | 97 ++-- .../amqp/broker/AMQPSessionCallback.java | 3 +- .../amqp/proton/AMQPConnectionContext.java | 15 +- .../proton/ProtonServerReceiverContext.java | 5 +- .../amqp/proton/ProtonServerSenderContext.java | 18 +- .../protocol/amqp/util/NettyReadable.java | 125 ++++- .../protocol/amqp/util/NettyWritable.java | 29 +- .../protocol/amqp/util/NettyReadableTest.java | 454 +++++++++++++++++++ .../protocol/amqp/util/NettyWritableTest.java | 151 ++++++ pom.xml | 4 +- .../integration/amqp/AmqpLargeMessageTest.java | 95 +++- 11 files changed, 917 insertions(+), 79 deletions(-) ----------------------------------------------------------------------
