Author: ritchiem
Date: Tue Nov 7 03:50:13 2006
New Revision: 472073
URL: http://svn.apache.org/viewvc?view=rev&rev=472073
Log:
TransactedTest.java - Added Logging around the setup.
Added a sleep after VM Broker creation to allow broker to startup.
Modified:
incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java?view=diff&rev=472073&r1=472072&r2=472073
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
Tue Nov 7 03:50:13 2006
@@ -205,6 +205,15 @@
Class[] cnstr = {Integer.class};
Object[] params = {port};
provider = (IoHandlerAdapter)
Class.forName(protocolProviderClass).getConstructor(cnstr).newInstance(params);
+ //Give the broker a second to create
+ try
+ {
+ Thread.sleep(1000);
+ }
+ catch (InterruptedException e)
+ {
+ //do nothing
+ }
}
catch (Exception e)
{
Modified:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java?view=diff&rev=472073&r1=472072&r2=472073
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java
Tue Nov 7 03:50:13 2006
@@ -92,14 +92,14 @@
// Sleep to ensure all queues have been created in the Broker.
try
{
- Thread.sleep(1000);
+ System.out.println("Finishing Setup");
+ Thread.sleep(3000);
}
catch (InterruptedException e)
{
//do nothing
}
-
-
+ System.out.println("Setup Complete");
}
@After
