You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ai...@apache.org on 2009/06/23 12:13:12 UTC
svn commit: r787623 - in
/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client:
QueueBrowserAutoAckTest.java failover/FailoverTest.java
Author: aidan
Date: Tue Jun 23 10:13:12 2009
New Revision: 787623
URL: http://svn.apache.org/viewvc?rev=787623&view=rev
Log:
QPID-1935: Use unique queue name per test run. *sigh*.
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java
Modified: qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java?rev=787623&r1=787622&r2=787623&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java (original)
+++ qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java Tue Jun 23 10:13:12 2009
@@ -61,7 +61,7 @@
setupSession();
- _queue = _clientSession.createQueue(getName());
+ _queue = _clientSession.createQueue(getName()+System.currentTimeMillis());
_clientSession.createConsumer(_queue).close();
//Ensure there are no messages on the queue to start with.
Modified: qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java?rev=787623&r1=787622&r2=787623&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java (original)
+++ qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/failover/FailoverTest.java Tue Jun 23 10:13:12 2009
@@ -82,9 +82,8 @@
protected void init(boolean transacted, int mode) throws JMSException, NamingException
{
- queue = (Queue) getInitialContext().lookup(QUEUE);
-
consumerSession = connection.createSession(transacted, mode);
+ queue = consumerSession.createQueue(getName()+System.currentTimeMillis());
consumer = consumerSession.createConsumer(queue);
producerSession = connection.createSession(transacted, mode);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org