static final Logger logger = LoggerFactory.getLogger(EventDispatcher.class);
private ExecutorService eventHandler;
- private BlockingQueue<AbstractEvent> events;
+ private volatile BlockingQueue<AbstractEvent> events;
private AbstractHandler[] handlers;
logger.info("The event handler thread was interrupted, shutting down", e);
return;
}
- dispatchEvent(ev);
+ try {
+ dispatchEvent(ev);
+ } catch (Exception e) {
+ logger.error("Exception in dispatching event "+ev.toString(), e);
+ }
}
}
});