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 2016/01/19 23:43:35 UTC
[5/5] activemq-artemis git commit: This closes #322
This closes #322
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/2d4654ca
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/2d4654ca
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/2d4654ca
Branch: refs/heads/master
Commit: 2d4654ca2631b98094c4021411447e201593b44d
Parents: c58209f 3f23c99
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue Jan 19 17:42:37 2016 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Jan 19 17:42:37 2016 -0500
----------------------------------------------------------------------
.../activemq/artemis/utils/uri/URIFactory.java | 9 +
.../activemq/artemis/utils/uri/URISchema.java | 7 +
.../activemq/artemis/utils/uri/URISupport.java | 560 +++++++++++++++++++
.../activemq/artemis/utils/URIParserTest.java | 6 +-
.../config/ActiveMQDefaultConfiguration.java | 8 +
.../artemis/api/core/client/TopologyMember.java | 2 +
.../core/client/impl/TopologyMemberImpl.java | 13 +
.../uri/AbstractServerLocatorSchema.java | 30 -
.../AbstractTransportConfigurationSchema.java | 26 -
.../activemq/artemis/uri/ConnectionOptions.java | 76 ---
.../ConnectorTransportConfigurationParser.java | 6 +-
.../artemis/uri/InVMServerLocatorSchema.java | 57 --
.../uri/InVMTransportConfigurationSchema.java | 69 ---
.../artemis/uri/JGroupsServerLocatorSchema.java | 89 ---
.../artemis/uri/ServerLocatorParser.java | 4 +
.../artemis/uri/TCPServerLocatorSchema.java | 121 ----
.../uri/TCPTransportConfigurationSchema.java | 90 ---
.../artemis/uri/UDPServerLocatorSchema.java | 82 ---
.../AbstractTransportConfigurationSchema.java | 26 +
.../InVMTransportConfigurationSchema.java | 69 +++
.../TCPTransportConfigurationSchema.java | 89 +++
.../AbstractServerLocatorSchema.java | 30 +
.../schema/serverLocator/ConnectionOptions.java | 76 +++
.../serverLocator/InVMServerLocatorSchema.java | 57 ++
.../JGroupsServerLocatorSchema.java | 89 +++
.../serverLocator/TCPServerLocatorSchema.java | 121 ++++
.../serverLocator/UDPServerLocatorSchema.java | 81 +++
.../artemis/utils/ConfigurationHelper.java | 31 +-
.../apache/activemq/artemis/uri/InVMSchema.java | 2 +
.../activemq/artemis/uri/JGroupsSchema.java | 1 +
.../artemis/uri/JMSConnectionOptions.java | 1 +
.../apache/activemq/artemis/uri/TCPSchema.java | 2 +
.../apache/activemq/artemis/uri/UDPSchema.java | 1 +
.../jms/server/embedded/EmbeddedJMS.java | 16 +-
.../config/ClusterConnectionConfiguration.java | 129 ++++-
.../artemis/core/config/Configuration.java | 6 +
.../core/config/impl/ConfigurationImpl.java | 35 +-
.../deployers/impl/FileConfigurationParser.java | 21 +-
.../core/server/ActiveMQServerLogger.java | 2 +-
.../core/server/cluster/BackupManager.java | 14 +-
.../cluster/ClusterConfigurationUtil.java | 87 ---
.../core/server/cluster/ClusterManager.java | 40 +-
.../core/server/cluster/ha/ScaleDownPolicy.java | 26 +-
.../cluster/impl/MessageLoadBalancingType.java | 31 +
.../core/server/embedded/EmbeddedActiveMQ.java | 43 +-
.../impl/SharedNothingLiveActivation.java | 17 +-
.../AcceptorTransportConfigurationParser.java | 6 +-
.../ClusterConnectionConfigurationParser.java | 31 +
...nVMAcceptorTransportConfigurationSchema.java | 27 -
...TCPAcceptorTransportConfigurationSchema.java | 34 --
...nVMAcceptorTransportConfigurationSchema.java | 28 +
...TCPAcceptorTransportConfigurationSchema.java | 35 ++
.../ClusterConnectionMulticastSchema.java | 48 ++
.../ClusterConnectionStaticSchema.java | 61 ++
.../resources/schema/artemis-configuration.xsd | 60 +-
.../impl/FileConfigurationParserTest.java | 18 +
.../artemis/tests/util/ActiveMQTestBase.java | 22 +-
.../uri/ClusterConnectionConfigurationTest.java | 65 +++
.../clustered-static-discovery-uri/pom.xml | 244 ++++++++
.../clustered-static-discovery-uri/readme.html | 58 ++
.../example/StaticClusteredQueueExample.java | 173 ++++++
.../main/resources/activemq/server0/broker.xml | 70 +++
.../main/resources/activemq/server1/broker.xml | 70 +++
.../main/resources/activemq/server2/broker.xml | 66 +++
.../main/resources/activemq/server3/broker.xml | 67 +++
.../clustered/clustered-topic-uri/pom.xml | 156 ++++++
.../clustered/clustered-topic-uri/readme.html | 46 ++
.../jms/example/ClusteredTopicExample.java | 129 +++++
.../main/resources/activemq/server0/broker.xml | 89 +++
.../main/resources/activemq/server1/broker.xml | 87 +++
examples/features/clustered/pom.xml | 4 +
.../cluster/distribution/ClusterTestBase.java | 18 +
.../distribution/URISimpleClusterTest.java | 130 +++++
73 files changed, 3347 insertions(+), 893 deletions(-)
----------------------------------------------------------------------