This closes #514 ARTEMIS-46 Adds AMQP Drain Support
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/0e0dec66 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/0e0dec66 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/0e0dec66 Branch: refs/heads/master Commit: 0e0dec66492877b91ed38cfa2f9d4d15bdf501a5 Parents: 0230a40 54752a9 Author: Andy Taylor <[email protected]> Authored: Wed May 11 12:09:53 2016 +0100 Committer: Andy Taylor <[email protected]> Committed: Wed May 11 12:09:53 2016 +0100 ---------------------------------------------------------------------- .../plug/ProtonSessionIntegrationCallback.java | 29 +++++++- artemis-protocols/artemis-proton-plug/pom.xml | 17 +++++ .../proton/plug/AMQPClientReceiverContext.java | 6 ++ .../org/proton/plug/AMQPSessionCallback.java | 2 +- .../plug/context/AbstractConnectionContext.java | 3 +- .../context/AbstractProtonContextSender.java | 2 +- .../context/AbstractProtonReceiverContext.java | 16 +++++ .../plug/context/ProtonDeliveryHandler.java | 2 +- .../plug/context/ProtonTransactionHandler.java | 2 +- .../client/ProtonClientReceiverContext.java | 3 +- .../server/ProtonServerReceiverContext.java | 2 +- .../server/ProtonServerSenderContext.java | 6 +- .../java/org/proton/plug/test/ProtonTest.java | 12 ++-- .../test/minimalserver/MinimalSessionSPI.java | 2 +- .../core/server/impl/ServerConsumerImpl.java | 26 ++++--- tests/integration-tests/pom.xml | 6 ++ .../tests/integration/proton/ProtonTest.java | 75 ++++++++++++++++++-- 17 files changed, 176 insertions(+), 35 deletions(-) ----------------------------------------------------------------------
