This closes #1553
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/b56950c3 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b56950c3 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b56950c3 Branch: refs/heads/1.x Commit: b56950c3511ffcea339c36b12ede8f00860e77a0 Parents: c85575f e03c41a Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Tue Sep 26 14:48:08 2017 -0400 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Tue Sep 26 14:48:08 2017 -0400 ---------------------------------------------------------------------- .../artemis/core/protocol/core/Packet.java | 7 + .../core/protocol/core/impl/PacketImpl.java | 1 + .../jms/server/ActiveMQJMSServerLogger.java | 4 +- .../artemis/core/io/AbstractSequentialFile.java | 7 + .../core/io/AbstractSequentialFileFactory.java | 5 + .../artemis/core/io/aio/AIOSequentialFile.java | 17 ++ .../core/io/aio/AIOSequentialFileFactory.java | 12 +- .../artemis/ra/ActiveMQResourceAdapter.java | 87 +++---- .../journal/AbstractJournalStorageManager.java | 2 +- .../impl/journal/JournalStorageManager.java | 24 +- .../impl/journal/LargeServerMessageImpl.java | 2 +- .../impl/journal/LargeServerMessageInSync.java | 10 + .../ReplicationLargeMessageEndMessage.java | 19 +- .../wireformat/ReplicationSyncFileMessage.java | 10 + .../replication/ReplicatedLargeMessage.java | 4 + .../core/replication/ReplicationEndpoint.java | 1 + .../core/replication/ReplicationManager.java | 98 ++++--- .../artemis/core/server/LargeServerMessage.java | 6 +- .../core/server/cluster/ClusterManager.java | 2 +- .../core/server/cluster/impl/BridgeImpl.java | 12 +- .../cluster/impl/ClusterConnectionBridge.java | 6 +- .../cluster/impl/ClusterConnectionImpl.java | 2 +- .../core/server/files/FileStoreMonitor.java | 8 +- .../core/server/impl/ActiveMQServerImpl.java | 2 +- .../core/server/impl/FileLockNodeManager.java | 74 ++++-- .../impl/SharedNothingLiveActivation.java | 2 +- .../core/server/files/FileStoreMonitorTest.java | 4 +- .../xa/recovery/ActiveMQXARecoveryLogger.java | 4 +- .../xa/recovery/XARecoveryConfig.java | 6 +- pom.xml | 8 + .../LargeMessageOverReplicationTest.java | 257 ------------------- ...MDBMultipleHandlersServerDisconnectTest.java | 3 +- tests/integration-tests/pom.xml | 6 - .../failover/FailoverTestWithDivert.java | 107 ++++++++ .../replication/ReplicationTest.java | 6 +- .../unit/core/journal/impl/TimedBufferTest.java | 5 +- 36 files changed, 418 insertions(+), 412 deletions(-) ----------------------------------------------------------------------
