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 2015/12/10 23:32:41 UTC
[5/5] activemq-artemis git commit: This closes #262
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 <cl...@apache.org>
Authored: Thu Dec 10 17:32:25 2015 -0500
Committer: Clebert Suconic <cl...@apache.org>
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(-)
----------------------------------------------------------------------