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:[email protected]
