BAEL-1018 - Introduction to MBassador (#2576)

* BAEL-1018 - Introduction to MBassador

* BAEL-1018 - Introduction to MBassador. Add type for some of the MBassadors.
This commit is contained in:
Eric Goebelbecker 2017-09-07 10:16:10 -04:00 committed by maibin
parent efbac53ec9
commit da32a94d12
4 changed files with 6 additions and 5 deletions

View File

@ -13,7 +13,7 @@ import static org.junit.Assert.assertNotNull;
public class MBassadorAsyncDispatchTest { public class MBassadorAsyncDispatchTest {
private MBassador dispatcher = new MBassador(); private MBassador dispatcher = new MBassador<String>();
private String testString; private String testString;
private AtomicBoolean ready = new AtomicBoolean(false); private AtomicBoolean ready = new AtomicBoolean(false);

View File

@ -17,7 +17,7 @@ import static org.junit.Assert.assertFalse;
public class MBassadorAsyncInvocationTest { public class MBassadorAsyncInvocationTest {
private MBassador dispatcher = new MBassador(); private MBassador dispatcher = new MBassador<Integer>();
private Integer testInteger; private Integer testInteger;
private String invocationThreadName; private String invocationThreadName;

View File

@ -24,8 +24,9 @@ public class MBassadorConfigurationTest implements IPublicationErrorHandler {
@Before @Before
public void prepareTests() { public void prepareTests() {
dispatcher = new MBassador(this);
dispatcher.subscribe(this); dispatcher = new MBassador<String>(this);
dispatcher.subscribe(this);
} }
@Test @Test

View File

@ -9,7 +9,7 @@ import static org.junit.Assert.*;
public class MBassadorHierarchyTest { public class MBassadorHierarchyTest {
private MBassador dispatcher = new MBassador(); private MBassador dispatcher = new MBassador<Message>();
private Message message; private Message message;
private AckMessage ackMessage; private AckMessage ackMessage;