You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2016/05/18 17:47:18 UTC
[4/4] activemq-artemis git commit: This closes #522
This closes #522
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/d728fe77
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/d728fe77
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/d728fe77
Branch: refs/heads/master
Commit: d728fe77182e9d0b628af83e356ceaed9dbb52c7
Parents: 664636d a75bd76
Author: jbertram <jb...@apache.org>
Authored: Wed May 18 12:46:44 2016 -0500
Committer: jbertram <jb...@apache.org>
Committed: Wed May 18 12:46:44 2016 -0500
----------------------------------------------------------------------
.../core/ChannelBroadcastEndpointFactory.java | 7 +-
.../api/core/JGroupsBroadcastEndpoint.java | 7 +-
.../api/core/jgroups/JChannelManager.java | 5 +-
.../api/core/jgroups/JChannelWrapper.java | 17 +-
.../api/core/jgroups/JGroupsReceiver.java | 7 +-
.../core/client/impl/ClientConsumerImpl.java | 119 +++++++--
.../client/impl/ClientSessionFactoryImpl.java | 80 +++---
.../core/client/impl/ClientSessionImpl.java | 49 ++--
.../core/client/impl/ServerLocatorImpl.java | 43 ++--
.../artemis/core/client/impl/Topology.java | 62 ++---
.../artemis/core/cluster/DiscoveryGroup.java | 13 +-
.../impl/ActiveMQClientProtocolManager.java | 8 +-
.../core/impl/ActiveMQConsumerContext.java | 7 +
.../core/impl/ActiveMQSessionContext.java | 7 +-
.../core/protocol/core/impl/ChannelImpl.java | 47 ++--
.../core/impl/RemotingConnectionImpl.java | 15 +-
.../remoting/impl/netty/NettyConnector.java | 10 +-
.../protocol/AbstractRemotingConnection.java | 5 +-
.../artemis/utils/OrderedExecutorFactory.java | 5 +-
.../artemis/utils/SoftValueHashMap.java | 9 +-
.../apache/activemq/artemis/utils/XMLUtil.java | 5 +-
.../jms/client/ActiveMQMessageConsumer.java | 8 +
.../artemis/jms/client/JMSExceptionHelper.java | 10 +
.../jms/client/JMSMessageListenerWrapper.java | 3 +
.../artemis/core/paging/PagingStoreFactory.java | 5 +
.../core/paging/cursor/NonExistentPage.java | 43 ++++
.../core/paging/cursor/PageCursorProvider.java | 3 +
.../core/paging/cursor/PageSubscription.java | 2 +-
.../paging/cursor/impl/LivePageCacheImpl.java | 6 +-
.../cursor/impl/PageCursorProviderImpl.java | 91 ++++---
.../cursor/impl/PageSubscriptionImpl.java | 53 +++-
.../activemq/artemis/core/paging/impl/Page.java | 4 +-
.../paging/impl/PageTransactionInfoImpl.java | 20 ++
.../core/paging/impl/PagingStoreFactoryNIO.java | 7 +
.../core/paging/impl/PagingStoreImpl.java | 11 +-
.../impl/journal/JournalStorageManager.java | 6 +-
.../impl/journal/LargeServerMessageImpl.java | 15 +-
.../postoffice/impl/DuplicateIDCacheImpl.java | 2 +-
.../server/impl/RemotingServiceImpl.java | 2 +
.../core/server/impl/ActiveMQServerImpl.java | 8 +-
.../artemis/core/server/impl/RefsOperation.java | 5 +
.../core/server/impl/ServerConsumerImpl.java | 8 +
.../tests/integration/client/PagingTest.java | 254 +++++++++++++++++++
.../core/paging/impl/PagingStoreImplTest.java | 14 +-
44 files changed, 828 insertions(+), 279 deletions(-)
----------------------------------------------------------------------