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<Subscription>();
 
-                    boolean isArray = type0.isArray();
-                    if (isArray) {
+                    // is this handler able to accept var args?
+                    if (handlerMetadata.getVarArgClass() != null) {
                         varArgPossibility.lazySet(true);
                     }