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 <[email protected]> Authored: Tue Sep 27 09:15:04 2016 -0400 Committer: Clebert Suconic <[email protected]> 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(-) ----------------------------------------------------------------------
