From 2247b5f24ccc7b43f70e59a62bce5c1ebe19bb6a Mon Sep 17 00:00:00 2001 From: nathan Date: Sun, 7 Jun 2015 23:36:29 +0200 Subject: [PATCH] Change bus default mode to better one. Fixed varArgPossibility to reflect actual state --- src/main/java/dorkbox/util/messagebus/MultiMBassador.java | 2 +- .../dorkbox/util/messagebus/subscription/Subscription.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/dorkbox/util/messagebus/MultiMBassador.java b/src/main/java/dorkbox/util/messagebus/MultiMBassador.java index 5999df4..56d07a3 100644 --- a/src/main/java/dorkbox/util/messagebus/MultiMBassador.java +++ b/src/main/java/dorkbox/util/messagebus/MultiMBassador.java @@ -51,7 +51,7 @@ public class MultiMBassador implements IMessageBus { * @param numberOfThreads how many threads to have for dispatching async messages */ public MultiMBassador(int numberOfThreads) { - this(PublishMode.ExactWithSuperTypesAndVarArgs, numberOfThreads); + this(PublishMode.ExactWithSuperTypes, numberOfThreads); } /** diff --git a/src/main/java/dorkbox/util/messagebus/subscription/Subscription.java b/src/main/java/dorkbox/util/messagebus/subscription/Subscription.java index 6bd22ab..c16a600 100644 --- a/src/main/java/dorkbox/util/messagebus/subscription/Subscription.java +++ b/src/main/java/dorkbox/util/messagebus/subscription/Subscription.java @@ -179,8 +179,8 @@ public final class Subscription { if (subs == null) { subs = new ArrayList(); - boolean isArray = type0.isArray(); - if (isArray) { + // is this handler able to accept var args? + if (handlerMetadata.getVarArgClass() != null) { varArgPossibility.lazySet(true); }