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 2016/04/15 03:14:52 UTC
[6/6] activemq-artemis git commit: This closes #463 ARTEMIS-474 and
ARTEMIS-484
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 <cl...@apache.org>
Authored: Thu Apr 14 21:14:17 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
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(-)
----------------------------------------------------------------------