dorkbox/MessageBus
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Updated to new constructor signature

Browse Source
This commit is contained in:
nathan 2019-06-07 12:35:21 +02:00
parent 89eee9ec9f
commit 6a2f5f8407
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/dorkbox/util/messagebus/MultiMessageTest.java
View File

@ -3,6 +3,8 @@
*/
package dorkbox.util.messagebus;
import static dorkbox.messageBus.IMessageBus.*;
import java.util.concurrent.atomic.AtomicInteger;
import org.junit.Test;
@ -23,7 +25,7 @@ public class MultiMessageTest extends MessageBusTest {
@Test
public void testMultiMessageSendingExact() {
IMessageBus bus = new MessageBus(IMessageBus.DispatchMode.Exact,
IMessageBus bus = new MessageBus(DispatchMode.Exact, PublicationMode.Disruptor, SubscriptionMode.StrongReferences,
Runtime.getRuntime()
.availableProcessors() / 2);
MultiListener listener1 = new MultiListener();
@ -54,7 +56,7 @@ public class MultiMessageTest extends MessageBusTest {
@Test
public void testMultiMessageSendingExactAndSuper() {
IMessageBus bus = new MessageBus(IMessageBus.DispatchMode.ExactWithSuperTypes,
IMessageBus bus = new MessageBus(DispatchMode.ExactWithSuperTypes, PublicationMode.Disruptor, SubscriptionMode.StrongReferences,
Runtime.getRuntime()
.availableProcessors() / 2);
MultiListener listener1 = new MultiListener();

5
test/dorkbox/util/messagebus/SubscriptionManagerTest.java
View File

@ -24,6 +24,7 @@ package dorkbox.util.messagebus;
import org.junit.Test;
import dorkbox.messageBus.IMessageBus.SubscriptionMode;
import dorkbox.messageBus.subscription.SubscriptionManager;
import dorkbox.util.messagebus.common.AssertSupport;
import dorkbox.util.messagebus.common.ConcurrentExecutor;
@ -227,7 +228,7 @@ public class SubscriptionManagerTest extends AssertSupport {
ListenerFactory listeners = listeners(Overloading.ListenerBase.class,
Overloading.ListenerSub.class);
final SubscriptionManager subscriptionManager = new SubscriptionManager(true);
final SubscriptionManager subscriptionManager = new SubscriptionManager(SubscriptionMode.StrongReferences);
ConcurrentExecutor.runConcurrent(TestUtil.subscriber(subscriptionManager, listeners), 1);
@ -254,7 +255,7 @@ public class SubscriptionManagerTest extends AssertSupport {
}
private void runTestWith(final ListenerFactory listeners, final SubscriptionValidator validator) {
final SubscriptionManager subscriptionManager = new SubscriptionManager(true);
final SubscriptionManager subscriptionManager = new SubscriptionManager(SubscriptionMode.StrongReferences);
ConcurrentExecutor.runConcurrent(TestUtil.subscriber(subscriptionManager, listeners), 1);