[jboss-cvs] JBoss Messaging SVN: r6188 - trunk/tests/src/org/jboss/messaging/tests/util.

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

Author: clebert.suconic at jboss.com
Date: 2009-03-26 17:45:40 -0400 (Thu, 26 Mar 2009)
New Revision: 6188

Modified:
   trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java
Log:
Adding slowConsumerTest

Modified: trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java	2009-03-26 21:35:40 UTC (rev 6187)
+++ trunk/tests/src/org/jboss/messaging/tests/util/ServiceTestBase.java	2009-03-26 21:45:40 UTC (rev 6188)
@@ -90,12 +90,13 @@
          try
          {
             Thread.sleep(500);
-         } catch (InterruptedException e)
+         }
+         catch (InterruptedException e)
          {
          }
       }
    }
-   
+
    // Constructors --------------------------------------------------
 
    // Public --------------------------------------------------------
@@ -148,16 +149,15 @@
       {
          service.getServer().getAddressSettingsRepository().addMatch(setting.getKey(), setting.getValue());
       }
-      
+
       AddressSettings defaultSetting = new AddressSettings();
       defaultSetting.setPageSizeBytes(configuration.getPagingGlobalWatermarkSize());
-      
+
       service.getServer().getAddressSettingsRepository().addMatch("#", defaultSetting);
 
       return service;
    }
 
-   
    protected MessagingService createService(final boolean realFiles,
                                             final Configuration configuration,
                                             final MBeanServer mbeanServer,
@@ -179,10 +179,10 @@
       {
          service.getServer().getAddressSettingsRepository().addMatch(setting.getKey(), setting.getValue());
       }
-      
+
       AddressSettings defaultSetting = new AddressSettings();
       defaultSetting.setPageSizeBytes(configuration.getPagingGlobalWatermarkSize());
-      
+
       service.getServer().getAddressSettingsRepository().addMatch("#", defaultSetting);
 
       return service;
@@ -269,7 +269,7 @@
       configuration.setJournalFileSize(100 * 1024);
       configuration.setPagingDirectory(getPageDir());
       configuration.setLargeMessagesDirectory(getLargeMessagesDir());
-      
+
       configuration.setJournalType(JournalType.NIO);
 
       configuration.getAcceptorConfigurations().clear();
@@ -303,7 +303,7 @@
    {
       return createTextMessage(session, s, true);
    }
-   
+
    public String getTextMessage(ClientMessage m)
    {
       m.getBody().resetReaderIndex();
@@ -331,7 +331,12 @@
       message.getBody().writeBytes(b);
       return message;
    }
-   
+
+   protected int getMessageCount(final MessagingService service, final String address) throws Exception
+   {
+      return getMessageCount(service.getServer().getPostOffice(), address);
+   }
+
    /**
     * @param address
     * @param postOffice
@@ -350,7 +355,7 @@
          if ((binding instanceof LocalQueueBinding))
          {
             QueueBinding qBinding = (QueueBinding)binding;
-            
+
             messageCount += qBinding.getQueue().getMessageCount();
 
          }
@@ -358,7 +363,6 @@
       return messageCount;
    }
 
-
    // Private -------------------------------------------------------
 
    // Inner classes -------------------------------------------------