diff --git a/src/main/java/org/mbassy/AbstractMessageBus.java b/src/main/java/org/mbassy/AbstractMessageBus.java index 9747408..65e3f32 100644 --- a/src/main/java/org/mbassy/AbstractMessageBus.java +++ b/src/main/java/org/mbassy/AbstractMessageBus.java @@ -24,17 +24,7 @@ public abstract class AbstractMessageBus } }; - // This is the default error handler it will simply log to standard out and - // print stack trace if available - protected static final class ConsoleLogger implements IPublicationErrorHandler { - @Override - public void handleError(PublicationError error) { - System.out.println(error); - if (error.getCause() != null) error.getCause().printStackTrace(); - } - } - ; // executor for asynchronous listeners using unbound queuing strategy to ensure that no events get lost private ExecutorService executor; @@ -98,7 +88,7 @@ public abstract class AbstractMessageBus public AbstractMessageBus(int dispatcherThreadCount, ExecutorService executor) { this.executor = executor; initDispatcherThreads(dispatcherThreadCount > 0 ? dispatcherThreadCount : 2); - addErrorHandler(new ConsoleLogger()); + addErrorHandler(new IPublicationErrorHandler.ConsoleLogger()); subscriptionFactory = getSubscriptionFactory(); initialize(); } diff --git a/src/main/java/org/mbassy/IPublicationErrorHandler.java b/src/main/java/org/mbassy/IPublicationErrorHandler.java index 14780c2..6143568 100644 --- a/src/main/java/org/mbassy/IPublicationErrorHandler.java +++ b/src/main/java/org/mbassy/IPublicationErrorHandler.java @@ -10,4 +10,16 @@ package org.mbassy; public interface IPublicationErrorHandler { public void handleError(PublicationError error); + + // This is the default error handler it will simply log to standard out and + // print stack trace if available + static final class ConsoleLogger implements IPublicationErrorHandler { + @Override + public void handleError(PublicationError error) { + System.out.println(error); + if (error.getCause() != null) error.getCause().printStackTrace(); + } + } + + ; } diff --git a/src/main/java/org/mbassy/common/ReflectionUtils.java b/src/main/java/org/mbassy/common/ReflectionUtils.java index 75b5b86..f03b088 100644 --- a/src/main/java/org/mbassy/common/ReflectionUtils.java +++ b/src/main/java/org/mbassy/common/ReflectionUtils.java @@ -1,8 +1,5 @@ package org.mbassy.common; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import java.lang.reflect.Field; import java.lang.reflect.Method; import java.util.LinkedList; @@ -15,8 +12,6 @@ import java.util.List; */ public class ReflectionUtils { - private static final Logger logger = LoggerFactory.getLogger(ReflectionUtils.class); - public static List getMethods(IPredicate condition, Class target) { List methods = new LinkedList(); try {