activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From andytay...@apache.org
Subject [1/9] activemq-artemis git commit: This closes #642 Flow control improvements
Date Wed, 20 Jul 2016 09:35:33 GMT
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 <andy.tayls67@gmail.com>
Authored: Wed Jul 20 10:33:44 2016 +0100
Committer: Andy Taylor <andy.tayls67@gmail.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message