This closes #262
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/8fa5bb2a Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8fa5bb2a Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8fa5bb2a Branch: refs/heads/master Commit: 8fa5bb2a0767c22bf7d49e59d97c53174467ffe3 Parents: a5a130b b1b4bb8 Author: Clebert Suconic <[email protected]> Authored: Thu Dec 10 17:32:25 2015 -0500 Committer: Clebert Suconic <[email protected]> Committed: Thu Dec 10 17:32:25 2015 -0500 ---------------------------------------------------------------------- .../cli/commands/tools/CompactJournal.java | 2 +- .../cli/commands/tools/DecodeJournal.java | 2 +- .../cli/commands/tools/EncodeJournal.java | 2 +- .../cli/commands/tools/XmlDataExporter.java | 2 +- .../artemis/cli/commands/etc/broker.xml | 4 +- .../config/ActiveMQDefaultConfiguration.java | 9 + .../client/impl/ClientSessionFactoryImpl.java | 20 - .../impl/ClientSessionFactoryInternal.java | 3 - .../core/client/impl/ClientSessionImpl.java | 14 +- .../core/client/impl/ClientSessionInternal.java | 4 +- .../core/client/impl/DelegatingSession.java | 6 +- .../core/impl/ActiveMQSessionContext.java | 6 + .../remoting/impl/netty/NettyConnection.java | 58 ++- .../remoting/impl/netty/NettyConnector.java | 4 + .../protocol/AbstractRemotingConnection.java | 6 + .../spi/core/protocol/RemotingConnection.java | 3 + .../artemis/spi/core/remoting/Connection.java | 8 +- .../spi/core/remoting/ReadyListener.java | 2 +- .../spi/core/remoting/SessionContext.java | 2 + .../journal/JMSJournalStorageManagerImpl.java | 2 +- .../artemis/core/io/aio/AIOSequentialFile.java | 7 +- .../journal/impl/JournalFilesRepository.java | 10 +- .../artemis/core/journal/impl/JournalImpl.java | 137 +++--- artemis-native/bin/libartemis-native-32.so | Bin 26721 -> 26789 bytes artemis-native/bin/libartemis-native-64.so | Bin 23497 -> 25003 bytes ...che_activemq_artemis_jlibaio_LibaioContext.c | 44 +- .../activemq/artemis/jlibaio/LibaioContext.java | 2 +- .../activemq/artemis/jlibaio/LibaioFile.java | 3 - .../artemis/jlibaio/test/LibaioTest.java | 33 +- .../plug/ActiveMQProtonConnectionCallback.java | 2 +- .../plug/ProtonSessionIntegrationCallback.java | 25 +- .../core/protocol/mqtt/MQTTConnection.java | 5 + .../artemis/core/protocol/mqtt/MQTTSession.java | 2 +- .../core/protocol/mqtt/MQTTSessionCallback.java | 21 +- .../protocol/openwire/OpenWireConnection.java | 4 + .../core/protocol/openwire/amq/AMQSession.java | 19 +- .../core/protocol/stomp/StompConnection.java | 5 + .../core/protocol/stomp/StompSession.java | 15 +- .../artemis/core/config/Configuration.java | 7 + .../core/config/impl/ConfigurationImpl.java | 14 + .../deployers/impl/FileConfigurationParser.java | 2 + .../impl/journal/DescribeJournal.java | 4 +- .../impl/journal/JournalStorageManager.java | 4 +- .../core/ServerSessionPacketHandler.java | 7 + .../core/impl/ActiveMQPacketHandler.java | 3 +- .../protocol/core/impl/CoreSessionCallback.java | 21 +- .../core/remoting/impl/invm/InVMConnection.java | 16 +- .../core/remoting/impl/netty/NettyAcceptor.java | 2 + .../core/server/cluster/impl/BridgeImpl.java | 40 +- .../core/server/impl/ServerConsumerImpl.java | 30 +- .../spi/core/protocol/SessionCallback.java | 6 +- .../resources/schema/artemis-configuration.xsd | 8 + .../artemis/tests/util/ActiveMQTestBase.java | 8 +- docs/user-manual/en/configuration-index.md | 1 + docs/user-manual/en/persistence.md | 12 + docs/user-manual/en/tools.md | 157 +++++-- scripts/one-test.sh | 19 + .../integration/client/ConsumerStuckTest.java | 4 +- .../integration/client/HangConsumerTest.java | 23 +- .../integration/client/JournalCrashTest.java | 2 +- .../tests/integration/client/PagingTest.java | 2 +- .../client/RedeliveryConsumerTest.java | 2 +- .../integration/cluster/bridge/BridgeTest.java | 2 +- .../journal/NIOJournalCompactTest.java | 4 +- .../journal/ValidateTransactionHealthTest.java | 2 +- .../journal/JournalImplTestUnit.java | 6 +- .../storage/PersistMultiThreadTest.java | 440 +++++++++++++++++++ .../storage/SendReceiveMultiThreadTest.java | 297 +++++++++++++ .../stress/journal/AddAndRemoveStressTest.java | 12 +- .../JournalCleanupCompactStressTest.java | 2 +- .../stress/journal/MixupCompactorTestBase.java | 2 +- .../NIOMultiThreadCompactorStressTest.java | 2 +- .../journal/impl/AlignedJournalImplTest.java | 10 +- .../core/journal/impl/JournalAsyncTest.java | 2 +- .../core/journal/impl/JournalImplTestBase.java | 14 +- .../core/journal/impl/JournalImplTestUnit.java | 109 ++++- .../impl/BatchIDGeneratorUnitTest.java | 2 +- 77 files changed, 1392 insertions(+), 401 deletions(-) ----------------------------------------------------------------------
