activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbert...@apache.org
Subject [2/2] activemq-artemis git commit: This closes #422
Date Wed, 16 Mar 2016 15:07:47 GMT
This closes #422


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ab98eb96
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ab98eb96
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ab98eb96

Branch: refs/heads/master
Commit: ab98eb9620bb5e53abf223e622fac2919b2808a7
Parents: ca19abb ee6a032
Author: jbertram <jbertram@apache.org>
Authored: Wed Mar 16 10:06:24 2016 -0500
Committer: jbertram <jbertram@apache.org>
Committed: Wed Mar 16 10:06:24 2016 -0500

----------------------------------------------------------------------
 .../activemq/artemis/utils/PendingTask.java     |  27 +++++
 .../protocol/proton/ProtonProtocolManager.java  |   2 +-
 .../plug/ProtonSessionIntegrationCallback.java  | 101 +++++++++++++------
 .../core/protocol/mqtt/MQTTSessionCallback.java |   6 ++
 .../openwire/amq/AMQServerConsumer.java         |   6 +-
 .../protocol/openwire/amq/AMQServerSession.java |   2 +-
 .../core/protocol/openwire/amq/AMQSession.java  |   5 +
 .../plug/AMQPConnectionContextFactory.java      |   4 +-
 .../plug/context/AbstractConnectionContext.java |  11 +-
 .../client/ProtonClientConnectionContext.java   |   8 +-
 .../ProtonClientConnectionContextFactory.java   |   8 +-
 .../server/ProtonServerConnectionContext.java   |   8 +-
 .../ProtonServerConnectionContextFactory.java   |   8 +-
 .../org/proton/plug/handler/ProtonHandler.java  |   9 +-
 .../plug/handler/impl/ProtonHandlerImpl.java    |  30 +++---
 .../context/AbstractConnectionContextTest.java  |   4 +-
 .../plug/test/invm/InVMTestConnector.java       |   4 +-
 .../proton/plug/test/invm/ProtonINVMSPI.java    |   2 +-
 .../test/minimalclient/SimpleAMQPConnector.java |   3 +-
 .../plug/test/minimalserver/MinimalServer.java  |   3 +-
 .../core/protocol/stomp/StompSession.java       |  32 +++++-
 .../protocol/core/impl/CoreSessionCallback.java |   6 ++
 .../core/server/ActiveMQServerLogger.java       |   5 +-
 .../core/server/impl/ServerConsumerImpl.java    |  66 +++++++++---
 .../core/server/impl/ServerSessionImpl.java     |   2 +-
 .../spi/core/protocol/SessionCallback.java      |   4 +
 .../integration/client/HangConsumerTest.java    |   5 +
 .../tests/integration/proton/ProtonTest.java    |   6 +-
 28 files changed, 270 insertions(+), 107 deletions(-)
----------------------------------------------------------------------



Mime
View raw message