You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/01/13 15:49:47 UTC
[8/8] activemq-artemis git commit: This closes #295
This closes #295
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a8c4ebd6
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a8c4ebd6
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a8c4ebd6
Branch: refs/heads/master
Commit: a8c4ebd6a4f920cf9f9acacb1b6e446ecf9dc552
Parents: aab09a7 64f74ac
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Jan 13 09:49:25 2016 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Jan 13 09:49:25 2016 -0500
----------------------------------------------------------------------
.gitignore | 1 +
.../artemis/cli/commands/tools/PrintData.java | 9 +-
.../cli/commands/tools/XmlDataExporter.java | 8 +-
.../config/ActiveMQDefaultConfiguration.java | 36 +
artemis-distribution/pom.xml | 5 +
artemis-distribution/src/main/assembly/dep.xml | 2 +
artemis-jdbc-store/pom.xml | 74 +
.../jdbc/store/journal/JDBCJournalImpl.java | 607 ++++
.../journal/JDBCJournalLoaderCallback.java | 110 +
.../journal/JDBCJournalReaderCallback.java | 124 +
.../jdbc/store/journal/JDBCJournalRecord.java | 319 ++
.../jdbc/store/journal/JDBCJournalSync.java | 40 +
.../jdbc/store/journal/TransactionHolder.java | 42 +
.../core/journal/PreparedTransactionInfo.java | 24 +-
.../artemis/core/journal/impl/JournalImpl.java | 4 +-
.../impl/dataformat/JournalAddRecord.java | 8 +-
artemis-server/pom.xml | 5 +
.../artemis/core/config/Configuration.java | 6 +-
.../artemis/core/config/StoreConfiguration.java | 29 +
.../core/config/impl/ConfigurationImpl.java | 16 +-
.../storage/DatabaseStorageConfiguration.java | 58 +
.../storage/FileStorageConfiguration.java | 58 +
.../deployers/impl/FileConfigurationParser.java | 46 +-
.../journal/AbstractJournalStorageManager.java | 1828 ++++++++++
.../persistence/impl/journal/AckDescribe.java | 34 +
.../impl/journal/AddMessageRecord.java | 12 +-
.../impl/journal/DescribeJournal.java | 57 +-
.../impl/journal/DummyOperationContext.java | 63 +
.../impl/journal/JDBCJournalStorageManager.java | 88 +
.../impl/journal/JournalRecordIds.java | 3 +-
.../impl/journal/JournalStorageManager.java | 3421 ++----------------
.../journal/LargeMessageTXFailureCallback.java | 64 +
.../TXLargeMessageConfirmationOperation.java | 46 +
.../journal/codec/CursorAckRecordEncoding.java | 61 +
.../impl/journal/codec/DeleteEncoding.java | 59 +
.../codec/DeliveryCountUpdateEncoding.java | 57 +
.../impl/journal/codec/DuplicateIDEncoding.java | 105 +
.../codec/FinishPageMessageOperation.java | 55 +
.../impl/journal/codec/GroupingEncoding.java | 75 +
.../codec/HeuristicCompletionEncoding.java | 58 +
.../journal/codec/LargeMessageEncoding.java | 52 +
.../journal/codec/PageCountPendingImpl.java | 79 +
.../impl/journal/codec/PageCountRecord.java | 68 +
.../impl/journal/codec/PageCountRecordInc.java | 64 +
.../journal/codec/PageUpdateTXEncoding.java | 64 +
.../codec/PendingLargeMessageEncoding.java | 60 +
.../codec/PersistentQueueBindingEncoding.java | 142 +
.../impl/journal/codec/QueueEncoding.java | 52 +
.../impl/journal/codec/RefEncoding.java | 28 +
.../codec/ScheduledDeliveryEncoding.java | 54 +
.../impl/journal/codec/XidEncoding.java | 52 +
.../wireformat/ReplicationStartSyncMessage.java | 12 +-
.../wireformat/ReplicationSyncFileMessage.java | 10 +-
.../core/replication/ReplicationEndpoint.java | 2 +-
.../core/replication/ReplicationManager.java | 10 +-
.../artemis/core/security/SecurityAuth.java | 2 +-
.../core/server/impl/ActiveMQServerImpl.java | 10 +-
.../resources/schema/artemis-configuration.xsd | 58 +
.../impl/DatabaseStoreConfigurationTest.java | 50 +
.../artemis/tests/util/ActiveMQTestBase.java | 18 +
.../test/resources/database-store-config.xml | 30 +
docs/user-manual/en/persistence.md | 58 +-
pom.xml | 13 +
tests/integration-tests/pom.xml | 5 +
.../tests/integration/client/PagingTest.java | 2 +-
.../store/journal/FakeEncodingSupportImpl.java | 46 +
.../jdbc/store/journal/JDBCJournalTest.java | 127 +
...AddressSettingsConfigurationStorageTest.java | 22 +-
.../DeleteMessagesOnStartupTest.java | 19 +-
.../persistence/DuplicateCacheTest.java | 5 +
...nnectionFactoryConfigurationStorageTest.java | 5 +
.../persistence/JMSStorageManagerTest.java | 5 +
.../RolesConfigurationStorageTest.java | 5 +
.../persistence/StorageManagerTestBase.java | 61 +-
.../journal/impl/AlignedJournalImplTest.java | 16 +-
.../core/journal/impl/JournalImplTestBase.java | 14 +-
76 files changed, 5871 insertions(+), 3166 deletions(-)
----------------------------------------------------------------------