You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/08/14 02:42:16 UTC
[4/4] activemq-artemis git commit: This closes #126 openwire fixes
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 <cl...@apache.org>
Authored: Thu Aug 13 20:42:00 2015 -0400
Committer: Clebert Suconic <cl...@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(-)
----------------------------------------------------------------------