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/06 16:17:35 UTC
[2/2] activemq-artemis git commit: This closes #111 openwire
refactoring
This closes #111 openwire refactoring
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/d4de6504
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/d4de6504
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/d4de6504
Branch: refs/heads/master
Commit: d4de65041b9f50b07c6a3246a8bc44584071caad
Parents: 5c7720d 8175673
Author: Clebert Suconic <cl...@apache.org>
Authored: Thu Aug 6 10:17:10 2015 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Thu Aug 6 10:17:10 2015 -0400
----------------------------------------------------------------------
.../protocol/openwire/OpenWireConnection.java | 292 +++++--------------
.../openwire/OpenWireProtocolManager.java | 59 ++--
.../amq/AMQCompositeConsumerBrokerExchange.java | 61 ++++
.../core/protocol/openwire/amq/AMQConsumer.java | 145 +++++++--
.../openwire/amq/AMQConsumerBrokerExchange.java | 17 +-
.../AMQMapTransportConnectionStateRegister.java | 151 ----------
.../core/protocol/openwire/amq/AMQSession.java | 49 ++--
.../amq/AMQSingleConsumerBrokerExchange.java | 46 +++
...QSingleTransportConnectionStateRegister.java | 184 ------------
.../amq/AMQTransportConnectionState.java | 85 ------
.../AMQTransportConnectionStateRegister.java | 59 ----
.../core/server/impl/ServerSessionImpl.java | 12 +
12 files changed, 382 insertions(+), 778 deletions(-)
----------------------------------------------------------------------