This closes #126 openwire fixes
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6c6568b7 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6c6568b7 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6c6568b7 Branch: refs/heads/master Commit: 6c6568b769f72cdb6f1e10662d0eca62d401902c Parents: 6b17d96 1dae997 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Thu Aug 13 20:42:00 2015 -0400 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Thu Aug 13 20:42:00 2015 -0400 ---------------------------------------------------------------------- .../artemis/api/core/ActiveMQBuffer.java | 7 +- .../core/buffers/impl/ChannelBufferWrapper.java | 26 ++- .../apache/activemq/artemis/utils/ByteUtil.java | 12 + .../CompressedLargeMessageControllerImpl.java | 30 ++- .../client/impl/LargeMessageControllerImpl.java | 23 +- .../artemis/reader/BytesMessageUtil.java | 106 ++++----- .../activemq/artemis/reader/MapMessageUtil.java | 17 +- .../activemq/artemis/reader/MessageUtil.java | 7 +- .../artemis/reader/StreamMessageUtil.java | 40 ++-- .../artemis/reader/TextMessageUtil.java | 7 +- .../jms/client/ActiveMQBytesMessage.java | 52 ++--- .../artemis/jms/client/ActiveMQMapMessage.java | 4 +- .../jms/client/ActiveMQStreamMessage.java | 22 +- .../artemis/jms/client/ActiveMQTextMessage.java | 4 +- .../converter/jms/ServerJMSBytesMessage.java | 53 ++--- .../converter/jms/ServerJMSMapMessage.java | 4 +- .../proton/converter/jms/ServerJMSMessage.java | 19 ++ .../converter/jms/ServerJMSStreamMessage.java | 84 ++++--- .../converter/jms/ServerJMSTextMessage.java | 6 +- .../core/protocol/proton/TestConversions.java | 20 +- .../protocol/openwire/DataInputWrapper.java | 228 ------------------- .../protocol/openwire/OpenWireConnection.java | 163 ++++++------- .../openwire/OpenWireMessageConverter.java | 23 +- .../openwire/OpenWireProtocolManager.java | 44 ++-- .../core/server/impl/ServerConsumerImpl.java | 6 - examples/features/perf/pom.xml | 4 +- .../openwire/SimpleOpenWireTest.java | 136 ++++++++--- .../openwire/VerySimpleOenwireTest.java | 118 ++++++++++ .../netty/ActiveMQFrameDecoder2Test.java | 8 +- 29 files changed, 648 insertions(+), 625 deletions(-) ----------------------------------------------------------------------