Repository: activemq-artemis Updated Branches: refs/heads/master 60036c93b -> 0e800d81a
This closes #1229 Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/0e800d81 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/0e800d81 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/0e800d81 Branch: refs/heads/master Commit: 0e800d81a7ea7fe90b8e225f43f0799bbdae71bd Parents: 60036c9 bad6acb Author: Martyn Taylor <[email protected]> Authored: Fri Apr 28 10:16:21 2017 +0100 Committer: Martyn Taylor <[email protected]> Committed: Fri Apr 28 10:16:21 2017 +0100 ---------------------------------------------------------------------- .../amqp/client/AmqpAbstractResource.java | 48 +- .../transport/amqp/client/AmqpReceiver.java | 154 +- .../transport/amqp/client/AmqpSender.java | 61 +- .../transport/amqp/client/AmqpValidator.java | 8 +- .../integration/amqp/AmqpClientTestSupport.java | 243 ++- .../amqp/AmqpDescribedTypePayloadTest.java | 11 +- .../amqp/AmqpDurableReceiverTest.java | 17 +- .../amqp/AmqpExpiredMessageTest.java | 67 +- .../integration/amqp/AmqpFlowControlTest.java | 284 +++ .../amqp/AmqpFullyQualifiedNameTest.java | 221 +++ .../amqp/AmqpInboundConnectionTest.java | 25 +- .../integration/amqp/AmqpManagementTest.java | 2 +- .../integration/amqp/AmqpMaxFrameSizeTest.java | 93 + .../amqp/AmqpMessageDivertsTest.java | 59 + .../amqp/AmqpMessageRoutingTest.java | 162 ++ .../amqp/AmqpOutboundConnectionTest.java | 70 + .../amqp/AmqpPresettledReceiverTest.java | 22 +- .../amqp/AmqpProtocolHeaderHandlingTest.java | 186 ++ .../amqp/AmqpReceiverDispositionTest.java | 19 - .../integration/amqp/AmqpReceiverDrainTest.java | 145 +- .../integration/amqp/AmqpReceiverTest.java | 298 +++ .../amqp/AmqpScheduledMessageTest.java | 2 +- .../integration/amqp/AmqpSecurityTest.java | 69 +- .../integration/amqp/AmqpSendReceiveTest.java | 346 ++-- .../tests/integration/amqp/AmqpSenderTest.java | 78 + .../tests/integration/amqp/AmqpSessionTest.java | 75 + .../tests/integration/amqp/AmqpTestSupport.java | 4 +- .../integration/amqp/AmqpTransactionTest.java | 21 +- .../amqp/BrokerDefinedAnycastConsumerTest.java | 31 +- .../BrokerDefinedMulticastConsumerTest.java | 21 +- .../amqp/ClientDefinedAnycastConsumerTest.java | 9 +- .../amqp/ClientDefinedMultiConsumerTest.java | 34 +- .../integration/amqp/JMSClientTestSupport.java | 151 ++ .../integration/amqp/JMSConnectionTest.java | 118 ++ .../amqp/JMSConnectionWithSecurityTest.java | 157 ++ .../amqp/JMSDurableConsumerTest.java | 202 ++ .../amqp/JMSMessageConsumerTest.java | 500 +++++ .../integration/amqp/JMSMessageGroupsTest.java | 102 + .../amqp/JMSMessageProducerTest.java | 221 +++ .../integration/amqp/JMSMessageTypesTest.java | 394 ++++ .../integration/amqp/JMSQueueBrowserTest.java | 296 +++ .../amqp/JMSTemporaryDestinationTest.java | 137 ++ .../integration/amqp/JMSTopicConsumerTest.java | 244 +++ .../integration/amqp/JMSTransactionTest.java | 216 +++ .../amqp/ProtonFullQualifiedNameTest.java | 237 --- .../amqp/ProtonMaxFrameSizeTest.java | 96 - .../integration/amqp/ProtonPubSubTest.java | 271 --- .../tests/integration/amqp/ProtonTest.java | 1788 ------------------ .../tests/integration/amqp/ProtonTestBase.java | 91 - .../integration/amqp/ProtonTestForHeader.java | 215 --- .../amqp/SendingAndReceivingTest.java | 224 --- 51 files changed, 4996 insertions(+), 3549 deletions(-) ----------------------------------------------------------------------
