You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2016/09/27 13:54:42 UTC
[15/15] activemq-artemis git commit: This closes #794
This closes #794
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/0ac9dbd5
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/0ac9dbd5
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/0ac9dbd5
Branch: refs/heads/master
Commit: 0ac9dbd573e85b585b554be6c88b75ea7b0a8da8
Parents: 4e34969 a838bf0
Author: Martyn Taylor <mt...@redhat.com>
Authored: Tue Sep 27 14:54:13 2016 +0100
Committer: Martyn Taylor <mt...@redhat.com>
Committed: Tue Sep 27 14:54:13 2016 +0100
----------------------------------------------------------------------
.../apache/activemq/artemis/utils/ByteUtil.java | 57 +
artemis-distribution/src/main/assembly/dep.xml | 1 -
.../src/main/resources/features.xml | 1 -
artemis-protocols/artemis-amqp-protocol/pom.xml | 5 -
.../ActiveMQProtonRemotingConnection.java | 142 --
.../protocol/proton/ProtonProtocolManager.java | 176 --
.../proton/ProtonProtocolManagerFactory.java | 64 -
.../proton/converter/ActiveMQJMSVendor.java | 151 --
.../converter/ProtonMessageConverter.java | 109 --
.../proton/converter/jms/ServerDestination.java | 37 -
.../converter/jms/ServerJMSBytesMessage.java | 208 ---
.../converter/jms/ServerJMSMapMessage.java | 291 ---
.../proton/converter/jms/ServerJMSMessage.java | 381 ----
.../converter/jms/ServerJMSObjectMessage.java | 79 -
.../converter/jms/ServerJMSStreamMessage.java | 364 ----
.../converter/jms/ServerJMSTextMessage.java | 99 -
.../converter/message/AMQPMessageIdHelper.java | 257 ---
.../converter/message/AMQPMessageTypes.java | 25 -
.../message/AMQPNativeInboundTransformer.java | 46 -
.../message/AMQPNativeOutboundTransformer.java | 60 -
.../message/AMQPRawInboundTransformer.java | 60 -
.../converter/message/EncodedMessage.java | 67 -
.../converter/message/InboundTransformer.java | 318 ----
.../message/JMSMappingInboundTransformer.java | 128 --
.../message/JMSMappingOutboundTransformer.java | 365 ----
.../proton/converter/message/JMSVendor.java | 53 -
.../converter/message/OutboundTransformer.java | 69 -
.../plug/ActiveMQProtonConnectionCallback.java | 285 ---
.../plug/ProtonSessionIntegrationCallback.java | 542 ------
.../protocol/proton/sasl/ActiveMQPlainSASL.java | 45 -
.../amqp/broker/AMQPConnectionCallback.java | 260 +++
.../amqp/broker/AMQPSessionCallback.java | 515 ++++++
.../ActiveMQProtonRemotingConnection.java | 142 ++
.../amqp/broker/ProtonProtocolManager.java | 172 ++
.../broker/ProtonProtocolManagerFactory.java | 64 +
.../protocol/amqp/broker/package-info.java | 23 +
.../amqp/converter/ActiveMQJMSVendor.java | 151 ++
.../amqp/converter/ProtonMessageConverter.java | 109 ++
.../amqp/converter/jms/ServerDestination.java | 37 +
.../converter/jms/ServerJMSBytesMessage.java | 208 +++
.../amqp/converter/jms/ServerJMSMapMessage.java | 291 +++
.../amqp/converter/jms/ServerJMSMessage.java | 381 ++++
.../converter/jms/ServerJMSObjectMessage.java | 79 +
.../converter/jms/ServerJMSStreamMessage.java | 364 ++++
.../converter/jms/ServerJMSTextMessage.java | 99 +
.../converter/message/AMQPMessageIdHelper.java | 257 +++
.../converter/message/AMQPMessageTypes.java | 25 +
.../message/AMQPNativeInboundTransformer.java | 46 +
.../message/AMQPNativeOutboundTransformer.java | 60 +
.../message/AMQPRawInboundTransformer.java | 60 +
.../amqp/converter/message/EncodedMessage.java | 67 +
.../converter/message/InboundTransformer.java | 318 ++++
.../message/JMSMappingInboundTransformer.java | 128 ++
.../message/JMSMappingOutboundTransformer.java | 365 ++++
.../amqp/converter/message/JMSVendor.java | 53 +
.../converter/message/OutboundTransformer.java | 69 +
.../protocol/amqp/converter/package-info.java | 21 +
.../amqp/exceptions/ActiveMQAMQPException.java | 42 +
.../ActiveMQAMQPIllegalStateException.java | 27 +
.../ActiveMQAMQPInternalErrorException.java | 31 +
.../ActiveMQAMQPInvalidFieldException.java | 27 +
.../ActiveMQAMQPNotFoundException.java | 27 +
.../ActiveMQAMQPNotImplementedException.java | 27 +
...iveMQAMQPResourceLimitExceededException.java | 27 +
.../ActiveMQAMQPTimeoutException.java | 28 +
.../ActiveMQAMQPProtocolMessageBundle.java | 80 +
.../amqp/proton/AMQPConnectionContext.java | 424 +++++
.../protocol/amqp/proton/AMQPConstants.java | 36 +
.../amqp/proton/AMQPSessionContext.java | 221 +++
.../protocol/amqp/proton/AmqpSupport.java | 131 ++
.../amqp/proton/ProtonDeliveryHandler.java | 39 +
.../amqp/proton/ProtonInitializable.java | 32 +
.../proton/ProtonServerReceiverContext.java | 211 +++
.../amqp/proton/ProtonServerSenderContext.java | 513 ++++++
.../amqp/proton/ProtonTransactionHandler.java | 141 ++
.../amqp/proton/handler/EventHandler.java | 78 +
.../protocol/amqp/proton/handler/Events.java | 102 ++
.../amqp/proton/handler/ExtCapability.java | 44 +
.../amqp/proton/handler/ProtonHandler.java | 357 ++++
.../protocol/amqp/proton/package-info.java | 22 +
.../protocol/amqp/sasl/AnonymousServerSASL.java | 34 +
.../artemis/protocol/amqp/sasl/PlainSASL.java | 44 +
.../protocol/amqp/sasl/PlainSASLResult.java | 44 +
.../artemis/protocol/amqp/sasl/SASLResult.java | 24 +
.../artemis/protocol/amqp/sasl/ServerSASL.java | 24 +
.../protocol/amqp/sasl/ServerSASLPlain.java | 63 +
.../artemis/protocol/amqp/util/CodecCache.java | 50 +
.../protocol/amqp/util/CreditsSemaphore.java | 110 ++
.../protocol/amqp/util/DeliveryUtil.java | 44 +
.../protocol/amqp/util/NettyWritable.java | 100 ++
.../protocol/amqp/util/ProtonServerMessage.java | 470 +++++
...mis.spi.core.protocol.ProtocolManagerFactory | 2 +-
.../core/protocol/proton/TestConversions.java | 793 --------
.../amqp/converter/TestConversions.java | 792 ++++++++
.../protocol/amqp/sasl/ClientSASLPlain.java | 54 +
.../protocol/amqp/sasl/PlainSASLTest.java | 34 +
.../amqp/util/CreditsSemaphoreTest.java | 134 ++
artemis-protocols/artemis-proton-plug/pom.xml | 137 --
.../plug/AMQPClientConnectionContext.java | 36 -
.../proton/plug/AMQPClientReceiverContext.java | 34 -
.../proton/plug/AMQPClientSenderContext.java | 27 -
.../proton/plug/AMQPClientSessionContext.java | 30 -
.../org/proton/plug/AMQPConnectionCallback.java | 58 -
.../org/proton/plug/AMQPConnectionContext.java | 71 -
.../plug/AMQPConnectionContextFactory.java | 39 -
.../plug/AMQPServerConnectionContext.java | 21 -
.../org/proton/plug/AMQPSessionCallback.java | 112 --
.../org/proton/plug/AMQPSessionContext.java | 34 -
.../main/java/org/proton/plug/AmqpSupport.java | 131 --
.../main/java/org/proton/plug/ClientSASL.java | 24 -
.../main/java/org/proton/plug/SASLResult.java | 24 -
.../main/java/org/proton/plug/ServerSASL.java | 24 -
.../org/proton/plug/context/AMQPConstants.java | 36 -
.../plug/context/AbstractConnectionContext.java | 360 ----
.../context/AbstractProtonContextSender.java | 153 --
.../context/AbstractProtonReceiverContext.java | 88 -
.../context/AbstractProtonSessionContext.java | 161 --
.../plug/context/ProtonDeliveryHandler.java | 39 -
.../plug/context/ProtonInitializable.java | 67 -
.../proton/plug/context/ProtonPlugSender.java | 26 -
.../plug/context/ProtonTransactionHandler.java | 143 --
.../client/ProtonClientConnectionContext.java | 107 --
.../ProtonClientConnectionContextFactory.java | 50 -
.../context/client/ProtonClientContext.java | 76 -
.../client/ProtonClientReceiverContext.java | 92 -
.../client/ProtonClientSessionContext.java | 145 --
.../server/ProtonServerConnectionContext.java | 94 -
.../ProtonServerConnectionContextFactory.java | 53 -
.../server/ProtonServerReceiverContext.java | 161 --
.../server/ProtonServerSenderContext.java | 452 -----
.../server/ProtonServerSessionContext.java | 117 --
.../plug/exceptions/ActiveMQAMQPException.java | 42 -
.../ActiveMQAMQPIllegalStateException.java | 27 -
.../ActiveMQAMQPInternalErrorException.java | 31 -
.../ActiveMQAMQPInvalidFieldException.java | 27 -
.../ActiveMQAMQPNotFoundException.java | 27 -
.../ActiveMQAMQPNotImplementedException.java | 27 -
...iveMQAMQPResourceLimitExceededException.java | 27 -
.../ActiveMQAMQPTimeoutException.java | 28 -
.../org/proton/plug/handler/EventHandler.java | 78 -
.../java/org/proton/plug/handler/Events.java | 105 --
.../org/proton/plug/handler/ExtCapability.java | 46 -
.../org/proton/plug/handler/ProtonHandler.java | 133 --
.../plug/handler/impl/DefaultEventHandler.java | 144 --
.../plug/handler/impl/ProtonHandlerImpl.java | 389 ----
.../ActiveMQAMQPProtocolMessageBundle.java | 80 -
.../proton/plug/sasl/AnonymousServerSASL.java | 37 -
.../org/proton/plug/sasl/ClientSASLPlain.java | 59 -
.../org/proton/plug/sasl/PlainSASLResult.java | 46 -
.../org/proton/plug/sasl/ServerSASLPlain.java | 66 -
.../java/org/proton/plug/util/ByteUtil.java | 130 --
.../java/org/proton/plug/util/CodecCache.java | 50 -
.../org/proton/plug/util/CreditsSemaphore.java | 110 --
.../java/org/proton/plug/util/DeliveryUtil.java | 44 -
.../org/proton/plug/util/FutureRunnable.java | 61 -
.../org/proton/plug/util/NettyWritable.java | 100 --
.../proton/plug/util/ProtonServerMessage.java | 470 -----
.../org/proton/plug/util/ReusableLatch.java | 130 --
.../context/AbstractConnectionContextTest.java | 137 --
.../org/proton/plug/test/AbstractJMSTest.java | 93 -
.../java/org/proton/plug/test/Constants.java | 22 -
.../java/org/proton/plug/test/ProtonTest.java | 335 ----
.../plug/test/invm/InVMTestConnector.java | 40 -
.../proton/plug/test/invm/ProtonINVMSPI.java | 240 ---
.../plug/test/minimalclient/AMQPClientSPI.java | 140 --
.../plug/test/minimalclient/Connector.java | 26 -
.../test/minimalclient/SimpleAMQPConnector.java | 76 -
.../plug/test/minimalserver/DumbServer.java | 52 -
.../minimalserver/MinimalConnectionSPI.java | 171 --
.../plug/test/minimalserver/MinimalServer.java | 167 --
.../test/minimalserver/MinimalSessionSPI.java | 229 ---
.../SimpleServerThreadFactory.java | 82 -
.../proton/plug/test/sasl/PlainSASLTest.java | 37 -
.../plug/test/util/CreditsSemaphoreTest.java | 135 --
.../plug/test/util/ReusableLatchTest.java | 300 ----
.../test/util/SimpleServerAbstractTest.java | 67 -
artemis-protocols/pom.xml | 1 -
tests/integration-tests/pom.xml | 12 -
.../amqp/ProtonMaxFrameSizeTest.java | 98 +
.../integration/amqp/ProtonPubSubTest.java | 257 +++
.../tests/integration/amqp/ProtonTest.java | 1548 ++++++++++++++++
.../tests/integration/amqp/ProtonTestBase.java | 77 +
.../integration/amqp/ProtonTestForHeader.java | 219 +++
.../amqp/SendingAndReceivingTest.java | 100 ++
.../amqp/jms/SendingAndReceivingTest.java | 100 --
.../proton/ProtonMaxFrameSizeTest.java | 98 -
.../integration/proton/ProtonPubSubTest.java | 337 ----
.../tests/integration/proton/ProtonTest.java | 1700 ------------------
.../integration/proton/ProtonTestBase.java | 77 -
.../integration/proton/ProtonTestForHeader.java | 219 ---
190 files changed, 11409 insertions(+), 15851 deletions(-)
----------------------------------------------------------------------