This closes #393
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/42b20ebf Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/42b20ebf Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/42b20ebf Branch: refs/heads/master Commit: 42b20ebf51891434387969962138e27c24cf54ca Parents: 418ef01 02afdbb Author: jbertram <[email protected]> Authored: Thu Feb 18 10:14:27 2016 -0600 Committer: jbertram <[email protected]> Committed: Thu Feb 18 10:14:27 2016 -0600 ---------------------------------------------------------------------- .../activemq/artemis/utils/uri/BeanSupport.java | 148 +++++++++++++++++++ .../activemq/artemis/utils/uri/URISchema.java | 127 ++-------------- .../activemq/artemis/utils/URIParserTest.java | 31 +++- .../api/core/TransportConfiguration.java | 90 +++++++---- .../client/impl/ClientSessionFactoryImpl.java | 6 +- .../impl/netty/ActiveMQChannelHandler.java | 6 +- .../remoting/impl/netty/NettyConnection.java | 6 +- .../remoting/impl/netty/NettyConnector.java | 17 ++- .../impl/netty/NettyConnectorFactory.java | 4 +- .../BaseConnectionLifeCycleListener.java | 60 ++++++++ .../ClientConnectionLifeCycleListener.java | 22 +++ .../remoting/ConnectionLifeCycleListener.java | 40 +---- .../spi/core/remoting/ConnectorFactory.java | 2 +- .../TCPTransportConfigurationSchema.java | 15 +- .../AbstractServerLocatorSchema.java | 3 +- .../serverLocator/InVMServerLocatorSchema.java | 3 +- .../JGroupsServerLocatorSchema.java | 7 +- .../serverLocator/TCPServerLocatorSchema.java | 7 +- .../serverLocator/UDPServerLocatorSchema.java | 9 +- .../activemq/artemis/uri/AbstractCFSchema.java | 3 +- .../apache/activemq/artemis/uri/InVMSchema.java | 3 +- .../activemq/artemis/uri/JGroupsSchema.java | 6 +- .../apache/activemq/artemis/uri/TCPSchema.java | 6 +- .../apache/activemq/artemis/uri/UDPSchema.java | 6 +- .../jms/server/embedded/EmbeddedJMS.java | 21 ++- .../proton/ProtonProtocolManagerFactory.java | 9 +- .../hornetq/HornetQProtocolManagerFactory.java | 18 ++- .../mqtt/MQTTProtocolManagerFactory.java | 9 +- .../OpenWireProtocolManagerFactory.java | 9 +- .../core/protocol/openwire/amq/AMQSession.java | 1 - .../proton/plug/util/ProtonServerMessage.java | 31 ---- .../stomp/StompProtocolManagerFactory.java | 11 +- .../artemis/core/protocol/ProtocolHandler.java | 4 + .../core/impl/CoreProtocolManagerFactory.java | 11 +- .../core/remoting/impl/AbstractAcceptor.java | 44 ++++++ .../core/remoting/impl/invm/InVMAcceptor.java | 19 ++- .../remoting/impl/invm/InVMAcceptorFactory.java | 8 +- .../core/remoting/impl/invm/InVMConnection.java | 10 +- .../core/remoting/impl/invm/InVMConnector.java | 22 ++- .../impl/invm/InVMConnectorFactory.java | 4 +- .../core/remoting/impl/netty/NettyAcceptor.java | 22 +-- .../impl/netty/NettyAcceptorFactory.java | 4 +- .../impl/netty/NettyServerConnection.java | 4 +- .../server/impl/RemotingServiceImpl.java | 93 ++++++------ .../cluster/impl/MessageLoadBalancingType.java | 4 +- .../AbstractProtocolManagerFactory.java | 2 +- .../core/protocol/ProtocolManagerFactory.java | 6 +- .../artemis/spi/core/remoting/Acceptor.java | 7 + .../spi/core/remoting/AcceptorFactory.java | 2 +- .../ServerConnectionLifeCycleListener.java | 12 +- .../ClusterConnectionMulticastSchema.java | 3 +- .../ClusterConnectionStaticSchema.java | 3 +- .../artemis/uri/AcceptorParserTest.java | 39 +++++ .../uri/ClusterConnectionConfigurationTest.java | 1 - examples/protocols/amqp/queue/pom.xml | 2 +- pom.xml | 2 +- tests/integration-tests/pom.xml | 2 +- .../impl/netty/NettyAcceptorFactoryTest.java | 7 +- .../remoting/impl/netty/NettyAcceptorTest.java | 7 +- .../server/impl/fake/FakeAcceptorFactory.java | 11 +- 60 files changed, 686 insertions(+), 405 deletions(-) ----------------------------------------------------------------------
