BAEL-1018 - Introduction to MBassador (eugenp#2576)

* BAEL-1018 - Introduction to MBassador * BAEL-1018 - Introduction to MBassador. Add type for some of the MBassadors.
zdougherty-softwarfare · Sep 7, 2017 · da32a94 · da32a94
1 parent efbac53
commit da32a94
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 5 deletions.
diff --git a/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncDispatchTest.java b/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncDispatchTest.java
@@ -13,7 +13,7 @@
 
 public class MBassadorAsyncDispatchTest {
 
-    private MBassador dispatcher = new MBassador();
+    private MBassador dispatcher = new MBassador<String>();
     private String testString;
     private AtomicBoolean ready = new AtomicBoolean(false);
 

diff --git a/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncInvocationTest.java b/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncInvocationTest.java
@@ -17,7 +17,7 @@
 
 public class MBassadorAsyncInvocationTest {
 
-    private MBassador dispatcher = new MBassador();
+    private MBassador dispatcher = new MBassador<Integer>();
 
     private Integer testInteger;
     private String invocationThreadName;

diff --git a/libraries/src/test/java/com/baeldung/mbassador/MBassadorConfigurationTest.java b/libraries/src/test/java/com/baeldung/mbassador/MBassadorConfigurationTest.java
@@ -24,8 +24,9 @@ public class MBassadorConfigurationTest implements IPublicationErrorHandler {
 
     @Before
     public void prepareTests() {
-        dispatcher = new MBassador(this);
-        dispatcher.subscribe(this);
+
+      dispatcher = new MBassador<String>(this);
+      dispatcher.subscribe(this);
     }
 
     @Test

diff --git a/libraries/src/test/java/com/baeldung/mbassador/MBassadorHierarchyTest.java b/libraries/src/test/java/com/baeldung/mbassador/MBassadorHierarchyTest.java
@@ -9,7 +9,7 @@
 
 public class MBassadorHierarchyTest {
 
-    private MBassador dispatcher = new MBassador();
+    private MBassador dispatcher = new MBassador<Message>();
 
     private Message message;
     private AckMessage ackMessage;