/[Apache-SVN]
ViewVC logotype

Revision 1084175


Jump to revision: Previous Next
Author: gtully
Date: Tue Mar 22 13:46:16 2011 UTC (13 years, 7 months ago)
Changed paths: 125 (showing only 100; show all)
Log Message:
https://issues.apache.org/jira/browse/AMQ-3236 - In the case of DLQ processing due to an exception from onMessage, provide the exception string as a message property. New property, org.apache.activemq.command.ActiveMQMessage#DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY will hold the string form of the exception that causes a posion ack for a dlq message. It may be null if the cause was regular calls to rollback or message expiry. Wireformat change to have exception included with messageAck. new version 7

Changed paths

Path Details
Directoryactivemq/trunk/activemq-core/pom.xml modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/SslBrokerService.java 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/TransportConnector.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/OpenTypeSupport.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.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/MessageAck.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQBlobMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQBytesMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQDestinationMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQMapMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQObjectMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQQueueMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQStreamMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQTempDestinationMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQTempQueueMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQTempTopicMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQTextMessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ActiveMQTopicMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/BaseCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/BaseDataStreamMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/BrokerIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/BrokerInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ConnectionControlMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ConnectionErrorMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ConnectionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ConnectionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ConsumerControlMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ConsumerIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ConsumerInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ControlCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/DataArrayResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/DataResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/DestinationInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/DiscoveryEventMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ExceptionResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/FlushCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/IntegerResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/JournalQueueAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/JournalTopicAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/JournalTraceMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/JournalTransactionMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/KeepAliveInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/LastPartialCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/LocalTransactionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/MarshallerFactory.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/MessageAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/MessageDispatchMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/MessageDispatchNotificationMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/MessageIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/MessageMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/MessagePullMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/NetworkBridgeFilterMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/PartialCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ProducerAckMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ProducerIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ProducerInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/RemoveInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/RemoveSubscriptionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ReplayCommandMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ResponseMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/SessionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/SessionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/ShutdownInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/SubscriptionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/TransactionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/TransactionInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/WireFormatInfoMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v7/XATransactionIdMarshaller.java added
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/MessageListenerRedeliveryTest.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/BaseCommandTestSupport.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/BrokerIdTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/BrokerInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ConnectionControlTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ConnectionErrorTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ConnectionIdTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ConnectionInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ConsumerControlTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ConsumerIdTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ConsumerInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ControlCommandTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/DataArrayResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/DataResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/DestinationInfoTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/DiscoveryEventTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/ExceptionResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/FlushCommandTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/IntegerResponseTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/JournalQueueAckTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/JournalTopicAckTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/JournalTraceTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v7/JournalTransactionTest.java added
[...]

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26