/[Apache-SVN]
ViewVC logotype

Revision 725323

Jump to revision: Previous Next
Author: gtully
Date: Wed Dec 10 16:23:07 2008 UTC (15 years, 11 months ago)
Changed paths: 125 (showing only 100; show all)
Log Message: 
resolve AMQ-2030, rev OpenWire version to 4 to accomadate additional field in ConsumerInfo that can hold array of networkConsumerIds that allows suppression of duplicate topic subscriptions in a cyclic network

Changed paths

Path Details
Directoryactivemq/trunk/activemq-core/pom.xml modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/MulticastNetworkConnector.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBlobMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBytesMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQDestinationMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQMapMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQObjectMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQQueueMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQStreamMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTempDestinationMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTempQueueMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTempTopicMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTextMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTopicMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/BaseCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/BaseDataStreamMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/BrokerIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/BrokerInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ConnectionControlMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ConnectionErrorMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ConnectionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ConnectionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ConsumerControlMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ConsumerIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ConsumerInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ControlCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/DataArrayResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/DataResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/DestinationInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/DiscoveryEventMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ExceptionResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/FlushCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/IntegerResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/JournalQueueAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/JournalTopicAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/JournalTraceMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/JournalTransactionMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/KeepAliveInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/LastPartialCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/LocalTransactionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/MarshallerFactory.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/MessageAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/MessageDispatchMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/MessageDispatchNotificationMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/MessageIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/MessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/MessagePullMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/NetworkBridgeFilterMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/PartialCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ProducerAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ProducerIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ProducerInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/RemoveInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/RemoveSubscriptionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ReplayCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/SessionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/SessionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/ShutdownInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/SubscriptionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/TransactionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/TransactionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/WireFormatInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v4/XATransactionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/BaseCommandTestSupport.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/BrokerIdTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/BrokerInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ConnectionControlTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ConnectionErrorTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ConnectionIdTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ConnectionInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ConsumerControlTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ConsumerIdTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ConsumerInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ControlCommandTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/DataArrayResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/DataResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/DestinationInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/DiscoveryEventTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/ExceptionResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/FlushCommandTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/IntegerResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/JournalQueueAckTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/JournalTopicAckTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/JournalTraceTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/JournalTransactionTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/KeepAliveInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/LastPartialCommandTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/LocalTransactionIdTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v4/MessageAckTest.java added
[...]
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26