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 2017/05/12 14:07:19 UTC
[6/6] activemq-artemis git commit: This closes #1263
This closes #1263
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/5e6687e0
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/5e6687e0
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/5e6687e0
Branch: refs/heads/master
Commit: 5e6687e0e2d1cd1f18ff74842863cbc9d22d06b7
Parents: b7b79e5 f1f4d4d
Author: Clebert Suconic <cl...@apache.org>
Authored: Fri May 12 10:06:43 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Fri May 12 10:06:43 2017 -0400
----------------------------------------------------------------------
.../artemis/cli/process/ProcessBuilder.java | 2 +-
.../artemis/core/server/NetworkHealthCheck.java | 2 +-
.../artemis/utils/ConcurrentHashSet.java | 81 --
.../activemq/artemis/utils/ConcurrentSet.java | 29 -
.../activemq/artemis/utils/DataConstants.java | 2 +-
.../activemq/artemis/utils/TypedProperties.java | 923 +-----------------
.../utils/collections/ConcurrentHashSet.java | 81 ++
.../collections/ConcurrentLongHashMap.java | 504 ++++++++++
.../collections/ConcurrentLongHashSet.java | 423 +++++++++
.../utils/collections/ConcurrentSet.java | 29 +
.../artemis/utils/collections/LinkedList.java | 32 +
.../utils/collections/LinkedListImpl.java | 390 ++++++++
.../utils/collections/LinkedListIterator.java | 32 +
.../utils/collections/PriorityLinkedList.java | 38 +
.../collections/PriorityLinkedListImpl.java | 248 +++++
.../utils/collections/TypedProperties.java | 939 +++++++++++++++++++
...uentPropertyBeanIntrospectorWithIgnores.java | 2 +-
.../artemis/utils/ConcurrentHashSetTest.java | 2 +
.../utils/TypedPropertiesConversionTest.java | 1 +
.../artemis/utils/TypedPropertiesTest.java | 1 +
.../collections/ConcurrentLongHashMapTest.java | 405 ++++++++
.../collections/ConcurrentLongHashSetTest.java | 249 +++++
.../core/client/impl/ClientConsumerImpl.java | 4 +-
.../core/client/impl/ClientMessageImpl.java | 2 +-
.../core/client/impl/ClientMessageInternal.java | 2 +-
.../client/impl/ClientSessionFactoryImpl.java | 2 +-
.../artemis/core/cluster/DiscoveryGroup.java | 2 +-
.../artemis/core/message/impl/CoreMessage.java | 2 +-
.../core/server/management/Notification.java | 2 +-
.../activemq/artemis/reader/MapMessageUtil.java | 2 +-
.../activemq/artemis/utils/LinkedList.java | 32 -
.../activemq/artemis/utils/LinkedListImpl.java | 390 --------
.../artemis/utils/LinkedListIterator.java | 32 -
.../artemis/utils/PriorityLinkedList.java | 38 -
.../artemis/utils/PriorityLinkedListImpl.java | 248 -----
.../util/TimeAndCounterIDGeneratorTest.java | 2 +-
.../store/file/JDBCSequentialFileFactory.java | 2 +-
.../artemis/jms/client/ActiveMQConnection.java | 2 +-
.../artemis/jms/client/ActiveMQJMSProducer.java | 2 +-
.../artemis/jms/client/ActiveMQMapMessage.java | 2 +-
.../artemis/jms/client/ThreadAwareContext.java | 2 +-
.../jms/server/impl/JMSServerManagerImpl.java | 4 +-
.../journal/impl/AbstractJournalUpdateTask.java | 9 +-
.../core/journal/impl/FileWrapperJournal.java | 13 +-
.../core/journal/impl/JournalCompactor.java | 20 +-
.../artemis/core/journal/impl/JournalImpl.java | 40 +-
.../journal/impl/JournalRecordProvider.java | 4 +-
.../amqp/converter/jms/ServerJMSMapMessage.java | 2 +-
.../protocol/mqtt/MQTTConnectionManager.java | 2 +-
.../protocol/mqtt/MQTTRetainMessageManager.java | 2 +-
.../protocol/openwire/OpenWireConnection.java | 2 +-
.../openwire/OpenWireMessageConverter.java | 2 +-
.../artemis/ra/ActiveMQRAConnectionManager.java | 2 +-
.../artemis/ra/recovery/RecoveryManager.java | 2 +-
.../impl/ActiveMQServerControlImpl.java | 4 +-
.../core/management/impl/QueueControlImpl.java | 2 +-
.../core/paging/cursor/PageIterator.java | 2 +-
.../core/paging/cursor/PageSubscription.java | 2 +-
.../cursor/impl/PageSubscriptionImpl.java | 2 +-
.../activemq/artemis/core/paging/impl/Page.java | 2 +-
.../core/paging/impl/PagingManagerImpl.java | 2 +-
.../impl/journal/LargeServerMessageImpl.java | 2 +-
.../core/postoffice/impl/PostOfficeImpl.java | 2 +-
.../core/remoting/impl/invm/InVMAcceptor.java | 2 +-
.../core/remoting/impl/netty/NettyAcceptor.java | 2 +-
.../core/replication/ReplicationEndpoint.java | 2 +-
.../core/security/impl/SecurityStoreImpl.java | 4 +-
.../activemq/artemis/core/server/Queue.java | 2 +-
.../core/server/cluster/ClusterManager.java | 2 +-
.../core/server/cluster/impl/BridgeImpl.java | 2 +-
.../server/cluster/impl/BroadcastGroupImpl.java | 2 +-
.../cluster/impl/ClusterConnectionImpl.java | 4 +-
.../group/impl/GroupHandlingAbstract.java | 2 +-
.../server/group/impl/LocalGroupingHandler.java | 2 +-
.../group/impl/RemoteGroupingHandler.java | 4 +-
.../core/server/impl/ActiveMQServerImpl.java | 7 +-
.../artemis/core/server/impl/QueueImpl.java | 10 +-
.../core/server/impl/ScaleDownHandler.java | 2 +-
.../core/server/impl/ServerConsumerImpl.java | 4 +-
.../core/server/impl/ServerSessionImpl.java | 15 +-
.../management/impl/ManagementServiceImpl.java | 4 +-
.../core/list/PriorityLinkedListTest.java | 4 +-
.../group/impl/ClusteredResetMockTest.java | 2 +-
.../impl/ScheduledDeliveryHandlerTest.java | 2 +-
etc/findbugs-exclude.xml | 2 +-
.../tests/integration/client/ConsumerTest.java | 2 +-
.../integration/client/SlowConsumerTest.java | 4 +-
.../integration/cluster/bridge/BridgeTest.java | 5 +-
.../integration/mqtt/imported/MQTTFQQNTest.java | 2 +-
.../integration/mqtt/imported/MQTTTest.java | 2 +-
.../integration/paging/PagingSendTest.java | 2 +-
.../integration/plugin/MqttPluginTest.java | 32 +-
.../JournalCleanupCompactStressTest.java | 14 +-
.../stress/paging/PageCursorStressTest.java | 2 +-
.../unit/core/postoffice/impl/FakeQueue.java | 5 +-
.../unit/core/server/impl/QueueImplTest.java | 2 +-
.../artemis/tests/unit/util/LinkedListTest.java | 4 +-
97 files changed, 3536 insertions(+), 1931 deletions(-)
----------------------------------------------------------------------