You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by an...@apache.org on 2015/01/13 10:23:04 UTC
[3/3] activemq-6 git commit: merge #61 - Improving ScaleDown and
allowing snapshots on builds
merge #61 - Improving ScaleDown and allowing snapshots on builds
Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/b388bf23
Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/b388bf23
Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/b388bf23
Branch: refs/heads/master
Commit: b388bf2397c8e0a96e6edfcabb030227a33adff9
Parents: ff7dbff ec9ff4f
Author: Andy Taylor <an...@gmail.com>
Authored: Tue Jan 13 09:21:33 2015 +0000
Committer: Andy Taylor <an...@gmail.com>
Committed: Tue Jan 13 09:21:33 2015 +0000
----------------------------------------------------------------------
.../activemq/utils/LinkedListIterator.java | 2 +-
.../cursor/impl/PageSubscriptionImpl.java | 18 +-
.../core/postoffice/AddressManager.java | 3 +
.../activemq/core/postoffice/PostOffice.java | 3 +
.../core/postoffice/impl/PostOfficeImpl.java | 5 +
.../postoffice/impl/SimpleAddressManager.java | 11 +
.../org/apache/activemq/core/server/Queue.java | 9 +-
.../impl/BackupRecoveryJournalLoader.java | 2 +-
.../core/server/impl/LiveOnlyActivation.java | 3 +-
.../activemq/core/server/impl/QueueImpl.java | 41 +-
.../core/server/impl/ScaleDownHandler.java | 619 +++++++++++--------
.../impl/ScheduledDeliveryHandlerTest.java | 4 +-
.../activemq/tests/util/ServiceTestBase.java | 2 +-
pom.xml | 2 +-
.../integration/client/HangConsumerTest.java | 5 +-
.../client/InterruptedLargeMessageTest.java | 4 +-
.../cluster/distribution/ClusterTestBase.java | 6 +-
.../integration/server/ScaleDownDirectTest.java | 319 ++++++++++
.../tests/integration/server/ScaleDownTest.java | 62 +-
.../unit/core/postoffice/impl/FakeQueue.java | 4 +-
.../core/server/impl/fakes/FakePostOffice.java | 7 +
21 files changed, 812 insertions(+), 319 deletions(-)
----------------------------------------------------------------------