You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2016/11/01 10:21:49 UTC
[20/34] activemq-artemis git commit: This closes #872
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/ARTEMIS-780
Commit: cdb52b8a0f7a2e7190685b2de634da4056f728db
Parents: 51fa840 7eadff7
Author: jbertram <jb...@apache.com>
Authored: Mon Oct 31 15:00:45 2016 -0500
Committer: jbertram <jb...@apache.com>
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(-)
----------------------------------------------------------------------