This closes #820
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/67f80405 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/67f80405 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/67f80405 Branch: refs/heads/master Commit: 67f804054d49fa55461e79565fc9a78486d85724 Parents: 6f6d984 62627bf Author: Clebert Suconic <[email protected]> Authored: Fri Oct 7 10:45:23 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Fri Oct 7 10:45:23 2016 -0400 ---------------------------------------------------------------------- .../amqp/broker/AMQPSessionCallback.java | 12 +- .../amqp/converter/ActiveMQJMSVendor.java | 148 --- .../amqp/converter/ProtonMessageConverter.java | 83 +- .../amqp/converter/jms/ServerJMSMessage.java | 9 +- .../converter/jms/ServerJMSObjectMessage.java | 47 +- .../message/AMQPContentTypeSupport.java | 146 +++ .../converter/message/AMQPMessageIdHelper.java | 59 +- .../converter/message/AMQPMessageSupport.java | 272 ++++++ .../converter/message/AMQPMessageTypes.java | 4 + .../message/AMQPNativeInboundTransformer.java | 28 +- .../message/AMQPNativeOutboundTransformer.java | 82 +- .../message/AMQPRawInboundTransformer.java | 48 +- .../amqp/converter/message/EncodedMessage.java | 12 +- .../converter/message/InboundTransformer.java | 182 ++-- .../message/JMSMappingInboundTransformer.java | 198 ++-- .../message/JMSMappingOutboundTransformer.java | 650 +++++++++---- .../amqp/converter/message/JMSVendor.java | 53 -- .../converter/message/OutboundTransformer.java | 78 +- ...ActiveMQAMQPInvalidContentTypeException.java | 27 + .../amqp/proton/ProtonServerSenderContext.java | 64 +- .../amqp/converter/TestConversions.java | 130 ++- .../message/AMQPContentTypeSupportTest.java | 230 +++++ .../message/AMQPMessageIdHelperTest.java | 391 ++++++++ .../message/AMQPMessageSupportTest.java | 108 +++ .../JMSMappingInboundTransformerTest.java | 718 ++++++++++++++ .../JMSMappingOutboundTransformerTest.java | 952 +++++++++++++++++++ .../JMSTransformationSpeedComparisonTest.java | 300 ++++++ .../message/MessageTransformationTest.java | 264 +++++ .../transport/amqp/client/AmqpMessage.java | 24 + .../tests/integration/amqp/ProtonTest.java | 71 +- 30 files changed, 4458 insertions(+), 932 deletions(-) ----------------------------------------------------------------------
