Repository: activemq-artemis Updated Branches: refs/heads/master 99a440b0d -> 28645b1b8
This closes #877 Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/28645b1b Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/28645b1b Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/28645b1b Branch: refs/heads/master Commit: 28645b1b83ffd8ee16e5746f8d796d6986b8c07e Parents: 99a440b d09f486 Author: jbertram <[email protected]> Authored: Wed Nov 2 13:17:12 2016 -0500 Committer: jbertram <[email protected]> Committed: Wed Nov 2 13:17:12 2016 -0500 ---------------------------------------------------------------------- .../activemq/artemis/cli/commands/Create.java | 8 +- .../cli/commands/util/SyncCalculation.java | 7 +- .../artemis/cli/commands/etc/broker.xml | 2 + .../apache/activemq/cli/test/ArtemisTest.java | 8 +- .../config/ActiveMQDefaultConfiguration.java | 7 + .../client/impl/ClientSessionFactoryImpl.java | 3 +- .../store/file/JDBCSequentialFileFactory.java | 12 + .../artemis/core/io/AbstractSequentialFile.java | 22 -- .../core/io/AbstractSequentialFileFactory.java | 15 ++ .../artemis/core/io/SequentialFileFactory.java | 4 + .../artemis/core/io/aio/AIOSequentialFile.java | 8 +- .../core/io/aio/AIOSequentialFileFactory.java | 2 +- .../core/io/mapped/MappedSequentialFile.java | 19 +- .../io/mapped/MappedSequentialFileFactory.java | 14 +- .../artemis/core/io/nio/NIOSequentialFile.java | 65 +---- artemis-native/bin/libartemis-native-32.so | Bin 26789 -> 26830 bytes artemis-native/bin/libartemis-native-64.so | Bin 25003 -> 28687 bytes ...che_activemq_artemis_jlibaio_LibaioContext.c | 11 +- .../activemq/artemis/jlibaio/LibaioContext.java | 12 +- .../artemis/jlibaio/test/LibaioTest.java | 10 +- .../jlibaio/test/OpenCloseContextTest.java | 8 +- .../amqp/broker/AMQPConnectionCallback.java | 2 +- .../amqp/broker/AMQPSessionCallback.java | 9 +- .../protocol/mqtt/MQTTConnectionManager.java | 3 +- .../protocol/openwire/OpenWireConnection.java | 107 +++++---- .../core/protocol/openwire/amq/AMQSession.java | 4 +- .../protocol/stomp/StompProtocolManager.java | 4 +- .../artemis/core/config/Configuration.java | 17 ++ .../core/config/impl/ConfigurationImpl.java | 13 + .../deployers/impl/FileConfigurationParser.java | 2 + .../impl/journal/JournalStorageManager.java | 4 + .../core/impl/ActiveMQPacketHandler.java | 5 +- .../artemis/core/server/ActiveMQServer.java | 6 +- .../core/server/impl/ActiveMQServerImpl.java | 9 +- .../resources/schema/artemis-configuration.xsd | 8 + .../core/config/impl/FileConfigurationTest.java | 2 + .../artemis/tests/util/ActiveMQTestBase.java | 2 +- .../resources/ConfigurationTest-full-config.xml | 1 + docs/user-manual/en/configuration-index.md | 1 + docs/user-manual/en/persistence.md | 4 + .../integration/persistence/SyncSendTest.java | 235 +++++++++++++++++++ .../vertx/ActiveMQVertxUnitTest.java | 5 +- .../impl/fakes/FakeSequentialFileFactory.java | 10 + 43 files changed, 505 insertions(+), 185 deletions(-) ----------------------------------------------------------------------
