[jboss-cvs] JBoss Messaging SVN: r2007 - trunk/tests/src/org/jboss/test/messaging/jms/clustering.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Sat Jan 20 17:26:24 EST 2007
Author: ovidiu.feodorov at jboss.com
Date: 2007-01-20 17:26:24 -0500 (Sat, 20 Jan 2007)
New Revision: 2007
Modified:
trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java
Log:
minor reformatting while closing http://jira.jboss.org/jira/browse/JBMESSAGING-696
Modified: trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java 2007-01-20 22:19:44 UTC (rev 2006)
+++ trunk/tests/src/org/jboss/test/messaging/jms/clustering/HATest.java 2007-01-20 22:26:24 UTC (rev 2007)
@@ -108,10 +108,11 @@
Connection[] conn = new Connection[]{conn1, conn2, conn3};
log.info("Connection delegate information after creation");
+
for (int i = 0; i < conn.length; i++)
{
- log.info("conn" + i + ".serverid=" + getServerId(conn[i]) + " conn" + i + ".ObjectID=" + getObjectId(conn[i])
- + " locatorURL=" + getLocatorURL(conn[i]));
+ log.info("conn" + i + ".serverid=" + getServerId(conn[i]) + " conn" + i + ".ObjectID=" +
+ getObjectId(conn[i]) + " locatorURL=" + getLocatorURL(conn[i]));
}
log.info("Killing server 1 and waiting 30 seconds for failover to kick in on client (from Lease)");
@@ -119,32 +120,36 @@
Thread.sleep(30000);
log.info("Connection delegate information after failover");
+
for (int i = 0; i < conn.length; i++)
{
- log.info("conn" + i + ".serverid=" + getServerId(conn[i]) + " conn" + i + ".ObjectID=" + getObjectId(conn[i])
- + " locatorURL=" + getLocatorURL(conn[i]));
+ log.info("conn" + i + ".serverid=" + getServerId(conn[i]) + " conn" + i + ".ObjectID=" +
+ getObjectId(conn[i]) + " locatorURL=" + getLocatorURL(conn[i]));
}
ConnectionState state2 = getConnectionState(conn2);
ConnectionState state3 = getConnectionState(conn3);
assertNotSame(state2.getRemotingConnection(), state3.getRemotingConnection());
- assertNotSame(state2.getRemotingConnection().getRemotingClient(), state3.getRemotingConnection().getRemotingClient());
+ assertNotSame(state2.getRemotingConnection().getRemotingClient(),
+ state3.getRemotingConnection().getRemotingClient());
+ conn1.close();
-
- conn1.close();
assertNotNull(state2.getRemotingConnection());
assertNotNull(state2.getRemotingConnection().getRemotingClient().getInvoker());
assertTrue(state2.getRemotingConnection().getRemotingClient().getInvoker().isConnected());
+
conn2.close();
- log.info("Closing connection 3 now");
-
assertNotNull(state3.getRemotingConnection());
assertNotNull(state3.getRemotingConnection().getRemotingClient().getInvoker());
assertTrue(state3.getRemotingConnection().getRemotingClient().getInvoker().isConnected());
- // When I created the testcase this was failing, throwing exceptions. This was basically why I created this testcase
+
+ log.info("Closing connection 3 now");
+
+ // When I created the testcase this was failing, throwing exceptions. This was basically why
+ // I created this testcase
conn3.close();
}
More information about the jboss-cvs-commits
mailing list