From c323e2928706656a8a2e0f77f8a51308b911048c Mon Sep 17 00:00:00 2001
From: nathan <nathan@dorkbox.com>
Date: Sat, 6 Feb 2016 16:23:14 +0100
Subject: [PATCH] comments/polish

---
 src/dorkbox/util/messagebus/MessageBus.java | 26 ++-------------------
 1 file changed, 2 insertions(+), 24 deletions(-)

diff --git a/src/dorkbox/util/messagebus/MessageBus.java b/src/dorkbox/util/messagebus/MessageBus.java
index 5a19c72..6e0165a 100644
--- a/src/dorkbox/util/messagebus/MessageBus.java
+++ b/src/dorkbox/util/messagebus/MessageBus.java
@@ -55,7 +55,6 @@ class MessageBus implements IMessageBus {
             }
         }
 
-
         // check to see if we can use the disruptor for publication (otherwise, we use native java). The disruptor is a lot faster, but
         // not available on all platforms/JRE's because of it's use of UNSAFE.
         if (useDisruptorForAsyncPublish) {
@@ -92,7 +91,6 @@ class MessageBus implements IMessageBus {
      */
     public
     MessageBus(int numberOfThreads) {
-//        this(PublishMode.ExactWithSuperTypesAndVarity, numberOfThreads);
         this(PublishMode.ExactWithSuperTypes, numberOfThreads);
     }
 
@@ -210,33 +208,13 @@ class MessageBus implements IMessageBus {
     @Override
     public
     void publishAsync(final Object message1, final Object message2) {
-//        if (message1 != null && message2 != null) {
-//            try {
-//                this.dispatchQueue.transfer(message1, message2);
-//            } catch (Exception e) {
-//                errorHandler.handlePublicationError(new PublicationError().setMessage(
-//                                "Error while adding an asynchronous message").setCause(e).setPublishedObject(message1, message2));
-//            }
-//        }
-//        else {
-//            throw new NullPointerException("Messages cannot be null.");
-//        }
+        publisher.publish(asyncPublication, message1, message2);
     }
 
     @Override
     public
     void publishAsync(final Object message1, final Object message2, final Object message3) {
-//        if (message1 != null || message2 != null | message3 != null) {
-//            try {
-//                this.dispatchQueue.transfer(message1, message2, message3);
-//            } catch (Exception e) {
-//                errorHandler.handlePublicationError(new PublicationError().setMessage(
-//                                "Error while adding an asynchronous message").setCause(e).setPublishedObject(message1, message2, message3));
-//            }
-//        }
-//        else {
-//            throw new NullPointerException("Messages cannot be null.");
-//        }
+        publisher.publish(asyncPublication, message1, message2, message3);
     }
 
     @Override