Repository: activemq-artemis Updated Branches: refs/heads/master fe27cd829 -> 413e7aee5
This closes #642 Flow control improvements Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/413e7aee Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/413e7aee Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/413e7aee Branch: refs/heads/master Commit: 413e7aee546dd5669a08bb90ac86ecc356c69c25 Parents: fe27cd8 4d60ced Author: Andy Taylor <[email protected]> Authored: Wed Jul 20 10:33:44 2016 +0100 Committer: Andy Taylor <[email protected]> Committed: Wed Jul 20 10:33:44 2016 +0100 ---------------------------------------------------------------------- .../plug/ProtonSessionIntegrationCallback.java | 64 +- .../org/proton/plug/AMQPSessionCallback.java | 2 + .../plug/context/AbstractConnectionContext.java | 2 +- .../context/AbstractProtonReceiverContext.java | 5 +- .../client/ProtonClientReceiverContext.java | 5 + .../server/ProtonServerConnectionContext.java | 1 - .../server/ProtonServerReceiverContext.java | 21 +- .../server/ProtonServerSenderContext.java | 4 +- .../test/minimalserver/MinimalSessionSPI.java | 7 +- docs/user-manual/en/flow-control.md | 48 +- tests/artemis-test-support/pom.xml | 57 ++ .../transport/amqp/AmqpProtocolException.java | 62 ++ .../activemq/transport/amqp/AmqpSupport.java | 206 ++++ .../amqp/client/AmqpAbstractResource.java | 321 +++++++ .../transport/amqp/client/AmqpClient.java | 245 +++++ .../transport/amqp/client/AmqpConnection.java | 720 ++++++++++++++ .../amqp/client/AmqpConnectionListener.java | 31 + .../client/AmqpDefaultConnectionListener.java | 28 + .../transport/amqp/client/AmqpEventSink.java | 69 ++ .../amqp/client/AmqpJmsSelectorFilter.java | 48 + .../transport/amqp/client/AmqpMessage.java | 515 ++++++++++ .../amqp/client/AmqpNoLocalFilter.java | 45 + .../transport/amqp/client/AmqpReceiver.java | 946 +++++++++++++++++++ .../amqp/client/AmqpRedirectedException.java | 61 ++ .../transport/amqp/client/AmqpResource.java | 108 +++ .../transport/amqp/client/AmqpSender.java | 452 +++++++++ .../transport/amqp/client/AmqpSession.java | 454 +++++++++ .../transport/amqp/client/AmqpSupport.java | 195 ++++ .../amqp/client/AmqpTransactionContext.java | 261 +++++ .../amqp/client/AmqpTransactionCoordinator.java | 262 +++++ .../amqp/client/AmqpTransactionId.java | 98 ++ .../amqp/client/AmqpTransferTagGenerator.java | 104 ++ .../amqp/client/AmqpUnknownFilterType.java | 49 + .../transport/amqp/client/AmqpValidator.java | 101 ++ .../amqp/client/sasl/AbstractMechanism.java | 97 ++ .../amqp/client/sasl/AnonymousMechanism.java | 43 + .../amqp/client/sasl/CramMD5Mechanism.java | 94 ++ .../transport/amqp/client/sasl/Mechanism.java | 143 +++ .../amqp/client/sasl/PlainMechanism.java | 76 ++ .../amqp/client/sasl/SaslAuthenticator.java | 182 ++++ .../client/transport/NettyTcpTransport.java | 402 ++++++++ .../amqp/client/transport/NettyTransport.java | 52 + .../client/transport/NettyTransportFactory.java | 80 ++ .../transport/NettyTransportListener.java | 46 + .../client/transport/NettyTransportOptions.java | 177 ++++ .../transport/NettyTransportSslOptions.java | 284 ++++++ .../client/transport/NettyTransportSupport.java | 288 ++++++ .../amqp/client/transport/NettyWSTransport.java | 472 +++++++++ .../PartialPooledByteBufAllocator.java | 134 +++ .../client/transport/X509AliasKeyManager.java | 86 ++ .../transport/amqp/client/util/AsyncResult.java | 46 + .../amqp/client/util/ClientFuture.java | 110 +++ .../util/ClientFutureSynchronization.java | 30 + .../amqp/client/util/IOExceptionSupport.java | 45 + .../transport/amqp/client/util/IdGenerator.java | 274 ++++++ .../amqp/client/util/NoOpAsyncResult.java | 40 + .../amqp/client/util/PropertyUtil.java | 533 +++++++++++ .../amqp/client/util/StringArrayConverter.java | 64 ++ .../amqp/client/util/TypeConversionSupport.java | 218 +++++ .../client/util/UnmodifiableConnection.java | 202 ++++ .../amqp/client/util/UnmodifiableDelivery.java | 170 ++++ .../amqp/client/util/UnmodifiableLink.java | 276 ++++++ .../amqp/client/util/UnmodifiableReceiver.java | 59 ++ .../amqp/client/util/UnmodifiableSender.java | 45 + .../amqp/client/util/UnmodifiableSession.java | 150 +++ .../amqp/client/util/UnmodifiableTransport.java | 274 ++++++ .../amqp/client/util/WrappedAsyncResult.java | 59 ++ tests/integration-tests/pom.xml | 5 + .../tests/integration/proton/ProtonTest.java | 207 +++- tests/pom.xml | 8 + 70 files changed, 11029 insertions(+), 39 deletions(-) ----------------------------------------------------------------------
