/[Apache-SVN]

Revision 902908

Jump to revision:
Author:	gtully
Date:	Mon Jan 25 18:19:54 2010 UTC (14 years, 8 months ago)
Changed paths:	129 (showing only 100; show all)
Log Message:	resolve: https://issues.apache.org/activemq/browse/AMQ-2579 - use ConsumerControl with destination to update prefetch once recovery is complete. restored consumers are pull only pending recovery completion on the client side. Update WireFormat version to 6 - fix for 5.4 due to wireformat update

Changed paths

Path	Details
activemq/trunk/activemq-core/pom.xml	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFilter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/EmptyBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ErrorBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/MutableBrokerFilter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerControl.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQBlobMessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQBytesMessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQDestinationMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQMapMessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQMessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQObjectMessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQQueueMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQStreamMessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQTempDestinationMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQTempQueueMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQTempTopicMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQTextMessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ActiveMQTopicMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/BaseCommandMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/BaseDataStreamMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/BrokerIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/BrokerInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ConnectionControlMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ConnectionErrorMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ConnectionIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ConnectionInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ConsumerControlMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ConsumerIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ConsumerInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ControlCommandMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/DataArrayResponseMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/DataResponseMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/DestinationInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/DiscoveryEventMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ExceptionResponseMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/FlushCommandMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/IntegerResponseMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/JournalQueueAckMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/JournalTopicAckMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/JournalTraceMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/JournalTransactionMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/KeepAliveInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/LastPartialCommandMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/LocalTransactionIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/MarshallerFactory.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/MessageAckMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/MessageDispatchMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/MessageDispatchNotificationMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/MessageIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/MessageMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/MessagePullMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/NetworkBridgeFilterMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/PartialCommandMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ProducerAckMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ProducerIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ProducerInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/RemoveInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/RemoveSubscriptionInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ReplayCommandMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ResponseMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/SessionIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/SessionInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/ShutdownInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/SubscriptionInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/TransactionIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/TransactionInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/WireFormatInfoMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v6/XATransactionIdMarshaller.java	added
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/BaseCommandTestSupport.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/BrokerIdTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/BrokerInfoTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ConnectionControlTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ConnectionErrorTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ConnectionIdTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ConnectionInfoTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ConsumerControlTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ConsumerIdTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ConsumerInfoTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ControlCommandTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/DataArrayResponseTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/DataResponseTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/DestinationInfoTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/DiscoveryEventTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/ExceptionResponseTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/FlushCommandTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/IntegerResponseTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/JournalQueueAckTest.java	added
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v6/JournalTopicAckTest.java	added
[...]

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26