1 files changed, 69 insertions, 68 deletions
diff --git a/plugins/org.eclipse.osee.framework.messaging.test/src/org/eclipse/osee/framework/messaging/services/internal/TestMessageServicesMultipleConsumers.java b/plugins/org.eclipse.osee.framework.messaging.test/src/org/eclipse/osee/framework/messaging/services/internal/TestMessageServicesMultipleConsumers.java
index e4f83983cf8..c128debea72 100644
--- a/plugins/org.eclipse.osee.framework.messaging.test/src/org/eclipse/osee/framework/messaging/services/internal/TestMessageServicesMultipleConsumers.java
+++ b/plugins/org.eclipse.osee.framework.messaging.test/src/org/eclipse/osee/framework/messaging/services/internal/TestMessageServicesMultipleConsumers.java
@@ -24,82 +24,83 @@ import org.eclipse.osee.framework.messaging.test.msg.TestMessage;
 
 /**
  * @author Andrew M. Finkbeiner
- *
  */
 public class TestMessageServicesMultipleConsumers extends BaseBrokerTesting implements OseeMessagingStatusCallback {
 
-	private static String BROKER_URI_SERVER = "tcp://localhost:61616";
-	private static String BROKER_URI = "tcp://localhost:61616";
-
-	@org.junit.Before
-	public void startBroker(){
-		try {
-			startEmbeddedBroker("testBroker", BROKER_URI_SERVER);
-		} catch (Exception ex) {
-			ex.printStackTrace();
-		}	
-	}
-	
-	@org.junit.After
-	public void stopBroker(){
-		try {
-			stopEmbeddedBroker("testBroker", BROKER_URI_SERVER);
-		} catch (Exception ex) {
-			ex.printStackTrace();
-		}	
-	}
-	
-	@org.junit.Test
-	public void testMultipleConsumers() throws Exception{
-		ConnectionNode connection = getMessaging().get(new NodeInfo("osee-jms", new URI(BROKER_URI)));
-		
-		List<BasicListener> listeners = new ArrayList<BasicListener>();
-		for(int i = 0; i < 20; i++){
-		   BasicListener listener = new BasicListener(i);
-		   listeners.add(listener);
-		   connection.subscribe(TestMessages.JMS_TOPIC, listener, this);
-		}
-		
-		TestMessage message = new TestMessage();
+   private static String BROKER_URI_SERVER = "tcp://localhost:61616";
+   private static String BROKER_URI = "tcp://localhost:61616";
+
+   @Override
+   @org.junit.Before
+   public void startBroker() {
+      try {
+         startEmbeddedBroker("testBroker", BROKER_URI_SERVER);
+      } catch (Exception ex) {
+         ex.printStackTrace();
+      }
+   }
+
+   @Override
+   @org.junit.After
+   public void stopBroker() {
+      try {
+         stopEmbeddedBroker("testBroker", BROKER_URI_SERVER);
+      } catch (Exception ex) {
+         ex.printStackTrace();
+      }
+   }
+
+   @org.junit.Test
+   public void testMultipleConsumers() throws Exception {
+      ConnectionNode connection = getMessaging().get(new NodeInfo("osee-jms", new URI(BROKER_URI)));
+
+      List<BasicListener> listeners = new ArrayList<BasicListener>();
+      for (int i = 0; i < 20; i++) {
+         BasicListener listener = new BasicListener(i);
+         listeners.add(listener);
+         connection.subscribe(TestMessages.JMS_TOPIC, listener, this);
+      }
+
+      TestMessage message = new TestMessage();
       message.setMessage("TestMessage 1");
       connection.send(TestMessages.JMS_TOPIC, message, this);
-      
+
       testWait(500);
 
-      for(BasicListener listener:listeners){
+      for (BasicListener listener : listeners) {
          assertTrue(listener.toString(), listener.isReceived());
       }
-	}
-
-	  @org.junit.Test
-	   public void testMultipleConsumersWithSelector() throws Exception{
-	      ConnectionNode connection = getMessaging().get(new NodeInfo("osee-jms", new URI(BROKER_URI)));
-	      
-	      List<BasicListener> listeners = new ArrayList<BasicListener>();
-	      for(int i = 0; i < 20; i++){
-	         BasicListener listener = new BasicListener(i);
-	         listeners.add(listener);
-	         connection.subscribe(TestMessages.JMS_TOPIC, listener, String.format("id = %d", i), this);
-	      }
-	      
-	      TestMessage message = new TestMessage();
-	      message.setMessage("TestMessage 1");
-	      Properties properties = new Properties();
-	      properties.put("id", 1);
-	      connection.send(TestMessages.JMS_TOPIC, message, properties, this);
-	      
-	      testWait(500);
-
-	      int receivedCount = 0;
-	      for(BasicListener listener:listeners){
-	         if(listener.isReceived()){
-	            receivedCount++;
-	         }
-	      }
-	      
-	      assertTrue(String.format("received %d messages", receivedCount), receivedCount == 1);
-	   }
-	
+   }
+
+   @org.junit.Test
+   public void testMultipleConsumersWithSelector() throws Exception {
+      ConnectionNode connection = getMessaging().get(new NodeInfo("osee-jms", new URI(BROKER_URI)));
+
+      List<BasicListener> listeners = new ArrayList<BasicListener>();
+      for (int i = 0; i < 20; i++) {
+         BasicListener listener = new BasicListener(i);
+         listeners.add(listener);
+         connection.subscribe(TestMessages.JMS_TOPIC, listener, String.format("id = %d", i), this);
+      }
+
+      TestMessage message = new TestMessage();
+      message.setMessage("TestMessage 1");
+      Properties properties = new Properties();
+      properties.put("id", 1);
+      connection.send(TestMessages.JMS_TOPIC, message, properties, this);
+
+      testWait(500);
+
+      int receivedCount = 0;
+      for (BasicListener listener : listeners) {
+         if (listener.isReceived()) {
+            receivedCount++;
+         }
+      }
+
+      assertTrue(String.format("received %d messages", receivedCount), receivedCount == 1);
+   }
+
    @Override
    public void fail(Throwable th) {
       assertTrue(th.getMessage(), false);
@@ -108,5 +109,5 @@ public class TestMessageServicesMultipleConsumers extends BaseBrokerTesting impl
    @Override
    public void success() {
    }
-	
+
 }