[jboss-cvs] JBoss Messaging SVN: r5655 - branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-01-18 18:28:34 -0500 (Sun, 18 Jan 2009)
New Revision: 5655

Modified:
   branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/MultiThreadRandomFailoverTestBase.java
Log:
Just auto-cleanup

Modified: branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/MultiThreadRandomFailoverTestBase.java
===================================================================
--- branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/MultiThreadRandomFailoverTestBase.java	2009-01-18 23:20:21 UTC (rev 5654)
+++ branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/MultiThreadRandomFailoverTestBase.java	2009-01-18 23:28:34 UTC (rev 5655)
@@ -94,6 +94,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestA(sf, threadNum);
@@ -105,6 +106,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestB(sf, threadNum);
@@ -116,6 +118,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestC(sf, threadNum);
@@ -127,6 +130,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestD(sf, threadNum);
@@ -138,6 +142,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestE(sf, threadNum);
@@ -149,6 +154,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestF(sf, threadNum);
@@ -160,6 +166,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestG(sf, threadNum);
@@ -171,6 +178,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestH(sf, threadNum);
@@ -182,6 +190,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestI(sf, threadNum);
@@ -193,6 +202,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestJ(sf, threadNum);
@@ -204,6 +214,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestK(sf, threadNum);
@@ -215,6 +226,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestL(sf);
@@ -237,6 +249,7 @@
    {
       runTestMultipleThreads(new RunnableT()
       {
+         @Override
          public void run(final ClientSessionFactory sf, final int threadNum) throws Exception
          {
             doTestN(sf, threadNum);
@@ -251,9 +264,8 @@
    protected abstract void start() throws Exception;
 
    protected abstract void setBody(ClientMessage message) throws Exception;
-   
-   protected abstract void checkSize(ClientMessage message);          
 
+   protected abstract void checkSize(ClientMessage message);
 
    protected void doTestA(final ClientSessionFactory sf, final int threadNum) throws Exception
    {
@@ -1224,18 +1236,20 @@
       return 20;
    }
 
+   @Override
    protected void setUp() throws Exception
    {
       super.setUp();
 
-      log.info("************ Starting test " + this.getName());
+      log.info("************ Starting test " + getName());
 
       timer = new Timer();
    }
 
+   @Override
    protected void tearDown() throws Exception
    {
-      log.info("************* Ending test " + this.getName());
+      log.info("************* Ending test " + getName());
 
       if (liveService != null && liveService.isStarted())
       {
@@ -1283,6 +1297,7 @@
                this.threadNum = threadNum;
             }
 
+            @Override
             public void run()
             {
                try
@@ -1337,7 +1352,6 @@
       }
    }
 
-
    private Failer startFailer(final long time, final ClientSession session)
    {
       Failer failer = new Failer(session);
@@ -1363,9 +1377,7 @@
       sf.setSendWindowSize(32 * 1024);
       return sf;
    }
-   
 
-
    private void stop() throws Exception
    {
       assertEquals(0, backupService.getServer().getRemotingService().getConnections().size());
@@ -1397,7 +1409,7 @@
          producer.send(message);
       }
    }
-   
+
    private void consumeMessages(final Set<ClientConsumer> consumers, final int numMessages, final int threadNum) throws Exception
    {
       // We make sure the messages arrive in the order they were sent from a particular producer
@@ -1463,6 +1475,7 @@
          this.session = session;
       }
 
+      @Override
       public synchronized void run()
       {
          log.info("** Failing connection");
@@ -1494,7 +1507,7 @@
 
       public void setFailed(final String reason, final Throwable throwable)
       {
-         this.failReason = reason;
+         failReason = reason;
          this.throwable = throwable;
       }
 
@@ -1517,7 +1530,7 @@
    {
       final CountDownLatch latch = new CountDownLatch(1);
 
-      private Map<Integer, Integer> counts = new HashMap<Integer, Integer>();
+      private final Map<Integer, Integer> counts = new HashMap<Integer, Integer>();
 
       volatile String failure;
 
@@ -1529,12 +1542,12 @@
 
       MyHandler(final int threadNum, final int numMessages)
       {
-         this.tn = threadNum;
+         tn = threadNum;
 
          this.numMessages = numMessages;
       }
 
-      public void onMessage(ClientMessage message)
+      public void onMessage(final ClientMessage message)
       {
          try
          {