This closes #1447
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/d4a7aebb Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/d4a7aebb Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/d4a7aebb Branch: refs/heads/master Commit: d4a7aebb6ddcf87c1c1455e43d378cdf44b41cde Parents: 246b8ef 1ace306 Author: Clebert Suconic <[email protected]> Authored: Tue Aug 8 14:00:59 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Tue Aug 8 14:00:59 2017 -0400 ---------------------------------------------------------------------- .../artemis/cli/commands/tools/PrintData.java | 6 +- .../cli/commands/tools/xml/XmlDataExporter.java | 6 +- .../activemq/artemis/utils/ExecutorFactory.java | 4 +- .../artemis/utils/actors/ArtemisExecutor.java | 69 ++++++++++++++++++++ .../artemis/utils/actors/OrderedExecutor.java | 2 +- .../utils/actors/OrderedExecutorFactory.java | 2 +- .../artemis/utils/actors/ProcessorBase.java | 4 ++ .../artemis/core/io/JournalTptBenchmark.java | 4 +- .../artemis/core/paging/PagingStoreFactory.java | 3 +- .../core/paging/cursor/PageSubscription.java | 5 +- .../cursor/impl/PageCursorProviderImpl.java | 6 +- .../cursor/impl/PageSubscriptionImpl.java | 8 +-- .../paging/impl/PagingStoreFactoryDatabase.java | 3 +- .../core/paging/impl/PagingStoreFactoryNIO.java | 3 +- .../core/paging/impl/PagingStoreImpl.java | 6 +- .../core/server/impl/LastValueQueue.java | 6 +- .../artemis/core/server/impl/QueueImpl.java | 58 +++++++++------- .../integration/client/HangConsumerTest.java | 7 +- .../client/InterruptedLargeMessageTest.java | 15 ++--- .../tests/integration/paging/PagingTest.java | 6 +- .../timing/core/server/impl/QueueImplTest.java | 9 ++- .../core/paging/impl/PagingStoreImplTest.java | 8 +-- .../unit/core/server/impl/QueueImplTest.java | 3 +- .../server/impl/fakes/FakeQueueFactory.java | 5 +- 24 files changed, 167 insertions(+), 81 deletions(-) ----------------------------------------------------------------------
