Added back messagebus

This commit is contained in:
nathan 2016-02-14 14:52:55 +01:00
parent 3370953b22
commit 8a743e8249

View File

@ -15,10 +15,10 @@
*/
package dorkbox.util;
import dorkbox.util.messagebus.IMessageBus;
import dorkbox.util.messagebus.MessageBus;
import dorkbox.util.messagebus.error.IPublicationErrorHandler;
import dorkbox.util.messagebus.error.PublicationError;
import dorkbox.messagebus.IMessageBus;
import dorkbox.messagebus.MessageBus;
import dorkbox.messagebus.error.IPublicationErrorHandler;
import dorkbox.messagebus.error.PublicationError;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -55,10 +55,7 @@ class MBus {
}
};
messageBus.getErrorHandler()
.addErrorHandler(ExceptionCounter);
messageBus.start();
messageBus.addErrorHandler(ExceptionCounter);
bus = messageBus;
}