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 2019/07/27 20:26:34 UTC

[activemq-artemis] 03/03: This closes #2773

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit 36534a387e8431ece1ab1e62e04dd3fa2730fcf9
Merge: f73d7f5 28ea18e
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Sat Jul 27 16:25:46 2019 -0400

    This closes #2773

 .../protocol/amqp/broker/AMQPSessionCallback.java  |  10 +-
 .../core/protocol/mqtt/MQTTPublishManager.java     |  24 +-
 .../core/protocol/mqtt/MQTTSessionCallback.java    |  14 +-
 .../core/protocol/openwire/amq/AMQSession.java     |  14 +-
 .../artemis/core/protocol/stomp/StompSession.java  |   3 +-
 .../impl/ManagementRemotingConnection.java         |  10 +-
 .../protocol/core/impl/CoreSessionCallback.java    |  10 +-
 .../activemq/artemis/core/server/Consumer.java     |  32 +--
 .../core/server/cluster/impl/BridgeImpl.java       |   2 +-
 .../core/server/cluster/impl/Redistributor.java    |   2 +-
 .../artemis/core/server/impl/QueueImpl.java        | 110 +++++----
 .../core/server/impl/ServerConsumerImpl.java       | 250 +++++++++++----------
 .../artemis/spi/core/protocol/SessionCallback.java |  10 +-
 .../tests/integration/cli/DummyServerConsumer.java |   2 +-
 .../tests/integration/client/HangConsumerTest.java |  10 +-
 .../tests/unit/core/server/impl/QueueImplTest.java |  17 +-
 .../unit/core/server/impl/fakes/FakeConsumer.java  |   2 +-
 17 files changed, 256 insertions(+), 266 deletions(-)