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 <clebertsuco...@apache.org> Authored: Wed Jan 13 09:49:25 2016 -0500 Committer: Clebert Suconic <clebertsuco...@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(-) ----------------------------------------------------------------------