activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbert...@apache.org
Subject [8/8] activemq-artemis git commit: This closes #872
Date Mon, 31 Oct 2016 20:01:18 GMT
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 <jbertram@apache.com>
Authored: Mon Oct 31 15:00:45 2016 -0500
Committer: jbertram <jbertram@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(-)
----------------------------------------------------------------------



Mime
View raw message