activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [6/6] activemq-artemis git commit: This closes #1263
Date Fri, 12 May 2017 14:07:19 GMT
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 <clebertsuconic@apache.org>
Authored: Fri May 12 10:06:43 2017 -0400
Committer: Clebert Suconic <clebertsuconic@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(-)
----------------------------------------------------------------------



Mime
View raw message