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 2016/09/27 13:25:19 UTC

[5/6] activemq-artemis git commit: This closes #804

This closes #804


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

Branch: refs/heads/master
Commit: e09a5acbdc1c397a7d85b1881281db728d620c60
Parents: 59489b4 447d784
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue Sep 27 09:15:04 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Sep 27 09:15:04 2016 -0400

----------------------------------------------------------------------
 .../activemq/artemis/utils/ConcurrentUtil.java  | 42 ++++++++++++++++
 .../core/protocol/core/impl/ChannelImpl.java    | 50 +++++++++-----------
 .../artemis/junit/ActiveMQConsumerResource.java |  2 +
 artemis-selector/pom.xml                        | 10 ++++
 .../server/group/impl/LocalGroupingHandler.java |  6 +--
 .../impl/AnyLiveNodeLocatorForReplication.java  |  9 ++--
 .../impl/AnyLiveNodeLocatorForScaleDown.java    |  9 ++--
 .../NamedLiveNodeLocatorForReplication.java     |  9 ++--
 .../impl/NamedLiveNodeLocatorForScaleDown.java  |  9 ++--
 pom.xml                                         |  8 +++-
 .../amqp/client/util/UnmodifiableLink.java      |  1 +
 .../integration/amqp/AmqpClientTestSupport.java |  2 +
 .../integration/cli/DestinationCommandTest.java |  1 +
 .../ExpireWhileLoadBalanceTest.java             |  1 +
 .../integration/paging/GlobalPagingTest.java    |  1 +
 .../proton/ProtonMaxFrameSizeTest.java          |  1 +
 .../integration/proton/ProtonPubSubTest.java    |  1 +
 .../rest/RestDeserializationTest.java           |  2 +
 .../tests/integration/rest/RestTestBase.java    |  2 +
 19 files changed, 118 insertions(+), 48 deletions(-)
----------------------------------------------------------------------