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 2017/09/26 18:49:05 UTC
[17/17] activemq-artemis git commit: This closes #1553
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 <cl...@apache.org>
Authored: Tue Sep 26 14:48:08 2017 -0400
Committer: Clebert Suconic <cl...@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(-)
----------------------------------------------------------------------