activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From martyntay...@apache.org
Subject [15/15] activemq-artemis git commit: This closes #794
Date Tue, 27 Sep 2016 13:54:42 GMT
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 <mtaylor@redhat.com>
Authored: Tue Sep 27 14:54:13 2016 +0100
Committer: Martyn Taylor <mtaylor@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(-)
----------------------------------------------------------------------



Mime
View raw message