You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2016/11/29 09:36:31 UTC
svn commit: r1771868 -
/qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/queue/LastValueQueueTest.java
Author: rgodfrey
Date: Tue Nov 29 09:36:30 2016
New Revision: 1771868
URL: http://svn.apache.org/viewvc?rev=1771868&view=rev
Log:
QPID-7546 : fix LastValueQueueTest
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/queue/LastValueQueueTest.java
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/queue/LastValueQueueTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/queue/LastValueQueueTest.java?rev=1771868&r1=1771867&r2=1771868&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/queue/LastValueQueueTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/server/queue/LastValueQueueTest.java Tue Nov 29 09:36:30 2016
@@ -365,13 +365,13 @@ public class LastValueQueueTest extends
Queue browseQueue;
if(isBroker10())
{
- AMQBindingURL url =
- new AMQBindingURL("direct://amq.direct//" + _queueName + "?browse='true'&durable='true'");
- browseQueue = new AMQQueue(url);
+ browseQueue = _consumerSession.createQueue(_queueName);
}
else
{
- browseQueue = _consumerSession.createQueue(_queueName);
+ AMQBindingURL url =
+ new AMQBindingURL("direct://amq.direct//" + _queueName + "?browse='true'&durable='true'");
+ browseQueue = new AMQQueue(url);
}
_consumer = _consumerSession.createConsumer(browseQueue);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org