This closes #872
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/cdb52b8a Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/cdb52b8a Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/cdb52b8a Branch: refs/heads/master Commit: cdb52b8a0f7a2e7190685b2de634da4056f728db Parents: 51fa840 7eadff7 Author: jbertram <[email protected]> Authored: Mon Oct 31 15:00:45 2016 -0500 Committer: jbertram <[email protected]> Committed: Mon Oct 31 15:00:45 2016 -0500 ---------------------------------------------------------------------- .../cli/commands/tools/DecodeJournal.java | 20 +- .../cli/commands/tools/XmlDataExporter.java | 14 +- .../activemq/artemis/utils/ExecutorFactory.java | 24 + .../artemis/utils/OrderedExecutorFactory.java | 127 +++ .../activemq/artemis/utils/SimpleFuture.java | 79 ++ .../artemis/utils/SimpleFutureTest.java | 69 ++ .../core/client/impl/ClientProducerImpl.java | 2 - .../core/client/impl/ClientSessionImpl.java | 26 +- .../core/client/impl/ClientSessionInternal.java | 2 - .../core/impl/ActiveMQSessionContext.java | 10 +- .../spi/core/remoting/SessionContext.java | 3 +- .../activemq/artemis/utils/ExecutorFactory.java | 24 - .../artemis/utils/OrderedExecutorFactory.java | 128 --- .../activemq/artemis/jdbc/store/JDBCUtils.java | 143 ---- .../jdbc/store/drivers/AbstractJDBCDriver.java | 76 +- .../artemis/jdbc/store/drivers/JDBCUtils.java | 66 ++ .../PostgresSequentialSequentialFileDriver.java | 164 ---- .../artemis/jdbc/store/file/JDBCFileUtils.java | 48 ++ .../jdbc/store/file/JDBCSequentialFile.java | 20 +- .../store/file/JDBCSequentialFileFactory.java | 10 +- .../file/JDBCSequentialFileFactoryDriver.java | 18 +- .../PostgresSequentialSequentialFileDriver.java | 162 ++++ .../jdbc/store/journal/JDBCJournalImpl.java | 27 +- .../journal/JDBCJournalLoaderCallback.java | 12 +- .../journal/JDBCJournalReaderCallback.java | 6 +- .../jdbc/store/journal/JDBCJournalRecord.java | 100 +-- .../jdbc/store/journal/JDBCJournalSync.java | 45 -- .../jdbc/store/journal/TransactionHolder.java | 4 +- .../file/JDBCSequentialFileFactoryTest.java | 10 +- .../journal/JMSJournalStorageManagerImpl.java | 6 +- .../jms/server/impl/JMSServerManagerImpl.java | 15 +- .../activemq/artemis/core/journal/Journal.java | 5 + .../core/journal/impl/FileWrapperJournal.java | 4 + .../artemis/core/journal/impl/JournalImpl.java | 791 +++++++++++-------- .../core/journal/impl/JournalTransaction.java | 48 +- .../artemis/journal/ActiveMQJournalLogger.java | 12 +- .../client/HornetQClientSessionContext.java | 5 +- .../artemis/osgi/DataSourceTracker.java | 2 +- .../impl/ActiveMQServerControlImpl.java | 6 +- .../core/management/impl/QueueControlImpl.java | 8 +- .../core/paging/cursor/PageSubscription.java | 5 +- .../impl/PageSubscriptionCounterImpl.java | 1 - .../cursor/impl/PageSubscriptionImpl.java | 24 +- .../journal/AbstractJournalStorageManager.java | 30 +- .../impl/journal/JDBCJournalStorageManager.java | 12 +- .../impl/journal/JournalStorageManager.java | 41 +- .../core/replication/ReplicatedJournal.java | 5 + .../artemis/core/server/ActiveMQServer.java | 2 + .../activemq/artemis/core/server/Queue.java | 2 +- .../artemis/core/server/ServiceRegistry.java | 4 + .../core/server/impl/ActiveMQServerImpl.java | 71 +- .../artemis/core/server/impl/QueueImpl.java | 67 +- .../core/server/impl/ScaleDownHandler.java | 4 +- .../core/server/impl/ServerConsumerImpl.java | 2 +- .../core/server/impl/ServiceRegistryImpl.java | 12 + .../impl/ScheduledDeliveryHandlerTest.java | 2 +- .../artemis/tests/util/ActiveMQTestBase.java | 28 +- .../extras/byteman/ClosingConnectionTest.java | 160 ---- .../byteman/JMSBridgeReconnectionTest.java | 2 +- .../tests/extras/byteman/PagingLeakTest.java | 14 +- .../tests/integration/client/ProducerTest.java | 6 +- .../cluster/failover/BackupSyncJournalTest.java | 2 +- .../journal/NIOJournalCompactTest.java | 195 +++-- .../journal/ValidateTransactionHealthTest.java | 27 +- .../management/ActiveMQServerControlTest.java | 9 +- .../integration/paging/PagingSendTest.java | 4 +- .../tests/integration/paging/PagingTest.java | 12 +- .../DeleteMessagesOnStartupTest.java | 2 +- .../integration/persistence/RestartSMTest.java | 2 +- .../persistence/StorageManagerTestBase.java | 6 +- .../replication/ReplicationTest.java | 7 +- .../server/SuppliedThreadPoolTest.java | 2 + .../journal/impl/AlignedJournalImplTest.java | 45 +- .../core/journal/impl/JournalAsyncTest.java | 15 +- .../core/journal/impl/JournalImplTestUnit.java | 80 +- .../impl/DuplicateDetectionUnitTest.java | 10 +- .../unit/core/postoffice/impl/FakeQueue.java | 2 +- .../unit/core/server/impl/QueueImplTest.java | 2 +- 78 files changed, 1763 insertions(+), 1494 deletions(-) ----------------------------------------------------------------------
