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 <[email protected]> Authored: Wed May 18 12:46:44 2016 -0500 Committer: jbertram <[email protected]> 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(-) ----------------------------------------------------------------------
