Author: rgodfrey
Date: Thu Aug 28 15:02:47 2014
New Revision: 1621150
URL: http://svn.apache.org/r1621150
Log:
QPID-6052 : Use ADDR addresses for JMSDestination on incoming messages in 0-9-1
when the address mode is ADDR
Modified:
qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
Modified:
qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java?rev=1621150&r1=1621149&r2=1621150&view=diff
==============================================================================
---
qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
(original)
+++
qpid/trunk/qpid/java/systests/src/test/java/org/apache/qpid/test/client/destination/AddressBasedDestinationTest.java
Thu Aug 28 15:02:47 2014
@@ -1209,7 +1209,7 @@ public class AddressBasedDestinationTest
private void replyToTest(String replyTo) throws Exception
{
Session session = _connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
- Destination replyToDest =
AMQDestination.createDestination(replyTo);
+ Destination replyToDest =
AMQDestination.createDestination(replyTo, false);
MessageConsumer replyToCons = session.createConsumer(replyToDest);
Destination dest = session.createQueue("ADDR:amq.direct/test");
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
