This closes #463 ARTEMIS-474 and ARTEMIS-484
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a3ae2c4a Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a3ae2c4a Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a3ae2c4a Branch: refs/heads/master Commit: a3ae2c4ad2f2b4e747d1926a3bc4a265f82639f8 Parents: 914d93f 630db2d Author: Clebert Suconic <[email protected]> Authored: Thu Apr 14 21:14:17 2016 -0400 Committer: Clebert Suconic <[email protected]> Committed: Thu Apr 14 21:14:17 2016 -0400 ---------------------------------------------------------------------- .../core/ChannelBroadcastEndpointFactory.java | 54 +++++- .../api/core/JGroupsBroadcastEndpoint.java | 167 ++---------------- .../core/JGroupsChannelBroadcastEndpoint.java | 6 +- .../api/core/JGroupsFileBroadcastEndpoint.java | 5 +- .../JGroupsFileBroadcastEndpointFactory.java | 7 +- .../JGroupsPropertiesBroadcastEndpoint.java | 8 +- ...roupsPropertiesBroadcastEndpointFactory.java | 6 +- .../api/core/jgroups/JChannelManager.java | 62 +++++++ .../api/core/jgroups/JChannelWrapper.java | 145 +++++++++++++++ .../api/core/jgroups/JGroupsReceiver.java | 72 ++++++++ .../core/client/impl/ClientMessageImpl.java | 2 +- .../core/client/impl/ServerLocatorImpl.java | 4 +- .../remoting/impl/netty/NettyConnection.java | 42 +++-- .../jms/client/ActiveMQJMSClientLogger.java | 8 +- .../jms/client/ActiveMQMessageConsumer.java | 14 +- .../jms/client/ActiveMQQueueBrowser.java | 2 +- .../jms/client/JMSMessageListenerWrapper.java | 2 +- .../artemis/core/io/aio/AIOSequentialFile.java | 10 +- .../artemis/core/io/util/FileIOUtil.java | 84 +++++++++ .../artemis/core/io/aio/FileIOUtilTest.java | 87 +++++++++ .../cursor/impl/PageCursorProviderImpl.java | 6 +- .../activemq/artemis/core/paging/impl/Page.java | 10 +- .../core/paging/impl/PagingStoreImpl.java | 8 +- .../impl/journal/LargeServerMessageInSync.java | 51 ++++-- .../ReplicationLargeMessageBeginMessage.java | 7 + .../ReplicationLargeMessageEndMessage.java | 7 + .../ReplicationLargeMessageWriteMessage.java | 8 + .../core/replication/ReplicationEndpoint.java | 176 ++++++++----------- .../core/replication/ReplicationManager.java | 12 +- .../core/server/cluster/ClusterController.java | 3 +- .../impl/SharedNothingBackupActivation.java | 108 +++++++++++- ...eOnSyncLargeMessageOverReplication2Test.java | 52 +++--- 32 files changed, 884 insertions(+), 351 deletions(-) ----------------------------------------------------------------------
