activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbert...@apache.org
Subject [4/4] activemq-artemis git commit: This closes #522
Date Wed, 18 May 2016 17:47:18 GMT
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 <jbertram@apache.org>
Authored: Wed May 18 12:46:44 2016 -0500
Committer: jbertram <jbertram@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(-)
----------------------------------------------------------------------



Mime
View raw message