You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2012/07/04 17:05:36 UTC
svn commit: r1357292 -
/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/StoreOverfullTest.java
Author: kwall
Date: Wed Jul 4 15:05:36 2012
New Revision: 1357292
URL: http://svn.apache.org/viewvc?rev=1357292&view=rev
Log:
QPID-4104: Create and bind second queue in test StoreOverfullTest#testCapacityExceededCausesBlockTwoConnections
Applied patch from Oleksandr Rudyy <or...@gmail.com>
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/StoreOverfullTest.java
Modified: qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/StoreOverfullTest.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/StoreOverfullTest.java?rev=1357292&r1=1357291&r2=1357292&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/StoreOverfullTest.java (original)
+++ qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/StoreOverfullTest.java Wed Jul 4 15:05:36 2012
@@ -157,6 +157,7 @@ public class StoreOverfullTest extends Q
AMQQueue queue2 = new AMQQueue(ExchangeDefaults.DIRECT_EXCHANGE_NAME, getTestQueueName() + "_2");
((AMQSession<?,?>) _producerSession).declareAndBind((AMQDestination)_queue);
+ ((AMQSession<?,?>) _producerSession).declareAndBind((AMQDestination)queue2);
_producer = _producerSession.createProducer(_queue);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org