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 #191 Protocol changes
Date Fri, 09 Oct 2015 02:55:57 GMT
This closes #191 Protocol changes


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/fcf18a76
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/fcf18a76
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/fcf18a76

Branch: refs/heads/master
Commit: fcf18a7644eefbebb00eed638075d98368266d9b
Parents: e30b983 a48046b
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Thu Oct 8 22:55:09 2015 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Thu Oct 8 22:55:09 2015 -0400

----------------------------------------------------------------------
 .../api/core/TransportConfiguration.java        |   11 +-
 .../artemis/api/core/client/ServerLocator.java  |   16 +-
 .../client/impl/ClientSessionFactoryImpl.java   |    2 +-
 .../core/client/impl/ServerLocatorImpl.java     |   83 +-
 .../core/client/impl/ServerLocatorInternal.java |    2 +-
 .../core/client/impl/TopologyMemberImpl.java    |    2 +-
 .../impl/ActiveMQClientProtocolManager.java     |   26 +-
 .../ActiveMQClientProtocolManagerFactory.java   |   21 +-
 .../core/impl/ActiveMQSessionContext.java       |   30 +-
 .../core/impl/wireformat/MessagePacket.java     |    2 +-
 .../core/impl/wireformat/MessagePacketI.java    |   24 +
 .../wireformat/SessionReceiveLargeMessage.java  |    8 +-
 .../wireformat/SessionSendLargeMessage.java     |    8 +-
 .../remoting/ClientProtocolManagerFactory.java  |    6 +
 .../jms/client/ActiveMQConnectionFactory.java   |   52 +
 .../artemis/uri/ConnectionFactoryURITest.java   |   13 +
 .../config/ConnectionFactoryConfiguration.java  |    6 +
 .../ConnectionFactoryConfigurationImpl.java     |   28 +-
 .../jms/server/impl/JMSServerManagerImpl.java   |    8 +-
 .../protocol/proton/ProtonProtocolManager.java  |    5 +
 .../HQPropertiesConversionInterceptor.java      |   68 +-
 .../hornetq/HornetQProtocolManager.java         |   12 +-
 .../hornetq/HornetQProtocolManagerFactory.java  |    5 +-
 .../client/HornetQClientProtocolManager.java    |   67 ++
 .../HornetQClientProtocolManagerFactory.java    |   46 +
 .../client/HornetQClientSessionContext.java     |  101 ++
 .../hornetq/util/HQPropertiesConverter.java     |   86 ++
 .../core/protocol/mqtt/MQTTProtocolManager.java |   10 +-
 .../openwire/OpenWireProtocolManager.java       |    5 +
 .../protocol/stomp/StompProtocolManager.java    |    5 +
 .../artemis/ra/ActiveMQResourceAdapter.java     |   20 +
 .../artemis/ra/ConnectionFactoryProperties.java |   17 +
 .../artemis/core/config/Configuration.java      |   11 +
 .../core/config/impl/ConfigurationImpl.java     |   30 +
 .../artemis/core/protocol/ProtocolHandler.java  |   10 +-
 .../protocol/core/impl/CoreProtocolManager.java |   23 +-
 ...ctiveMQServerSideProtocolManagerFactory.java |   20 +-
 .../core/server/cluster/BackupManager.java      |    4 +-
 .../core/server/cluster/ClusterController.java  |    4 +-
 .../cluster/impl/ClusterConnectionBridge.java   |    2 +-
 .../cluster/impl/ClusterConnectionImpl.java     |    4 +-
 .../impl/BackupRecoveryJournalLoader.java       |   10 +-
 .../core/server/impl/LiveOnlyActivation.java    |    2 +-
 .../spi/core/protocol/ProtocolManager.java      |    5 +
 .../artemis/tests/util/ActiveMQTestBase.java    |   16 +
 .../xa/recovery/ActiveMQXAResourceRecovery.java |    2 +-
 .../xa/recovery/XARecoveryConfig.java           |   46 +-
 .../tests/recovery/XARecoveryConfigTest.java    |   67 ++
 .../standard/interceptor-client/pom.xml         |  110 ++
 .../standard/interceptor-client/readme.html     |   72 ++
 .../artemis/jms/example/InterceptorExample.java |   74 ++
 .../artemis/jms/example/SimpleInterceptor.java  |   48 +
 examples/features/standard/pom.xml              |    2 +
 .../hornetq/HornetQProtocolManagerTest.java     |  138 +++
 .../protocols/hornetq/HornetQProtocolTest.java  |   55 +-
 .../tests/integration/InterceptorTest.java      | 1030 -----------------
 .../cluster/ClusterControllerTest.java          |    4 +-
 .../cluster/distribution/ClusterTestBase.java   |    2 +-
 .../integration/interceptors/Incoming.java      |   42 +
 .../interceptors/InterceptorTest.java           | 1089 ++++++++++++++++++
 .../integration/interceptors/Outgoing.java      |   41 +
 .../integration/jms/client/ConnectionTest.java  |   39 +-
 .../ra/ActiveMQResourceAdapterConfigTest.java   |    6 +
 .../ra/ConnectionFactoryPropertiesTest.java     |    2 +
 64 files changed, 2625 insertions(+), 1180 deletions(-)
----------------------------------------------------------------------



Mime
View raw message