From da32a94d12307b5677ff630a773ee715f3ec6c92 Mon Sep 17 00:00:00 2001
From: Eric Goebelbecker <egoebelbecker@users.noreply.github.com>
Date: Thu, 7 Sep 2017 10:16:10 -0400
Subject: [PATCH] BAEL-1018 - Introduction to MBassador (#2576)

* BAEL-1018 - Introduction to MBassador

* BAEL-1018 - Introduction to MBassador. Add type for some of the MBassadors.
---
 .../com/baeldung/mbassador/MBassadorAsyncDispatchTest.java   | 2 +-
 .../com/baeldung/mbassador/MBassadorAsyncInvocationTest.java | 2 +-
 .../com/baeldung/mbassador/MBassadorConfigurationTest.java   | 5 +++--
 .../java/com/baeldung/mbassador/MBassadorHierarchyTest.java  | 2 +-
 4 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncDispatchTest.java b/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncDispatchTest.java
index a0648aa4e1..0cab612a7b 100644
--- a/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncDispatchTest.java
+++ b/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncDispatchTest.java
@@ -13,7 +13,7 @@ import static org.junit.Assert.assertNotNull;
 
 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
index d20c887309..d0b1cafd71 100644
--- a/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncInvocationTest.java
+++ b/libraries/src/test/java/com/baeldung/mbassador/MBassadorAsyncInvocationTest.java
@@ -17,7 +17,7 @@ import static org.junit.Assert.assertFalse;
 
 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
index d1e711999c..fe9c130d93 100644
--- 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
index 87d6a621a4..be5c9d4897 100644
--- a/libraries/src/test/java/com/baeldung/mbassador/MBassadorHierarchyTest.java
+++ b/libraries/src/test/java/com/baeldung/mbassador/MBassadorHierarchyTest.java
@@ -9,7 +9,7 @@ import static org.junit.Assert.*;
 
 public class MBassadorHierarchyTest {
 
-    private MBassador dispatcher = new MBassador();
+    private MBassador dispatcher = new MBassador<Message>();
 
     private Message message;
     private AckMessage ackMessage;