eventHandler.submit(new Runnable() {
@Override
public void run() {
+ Thread t = Thread.currentThread();
+ logger.info("Thread = {}", t);
+ t.setName("EventDispatcherImpl");
+ logger.info("Thread = {}", t);
while (true) {
AbstractEvent ev;
try {
return;
}
+ logger.info("EventDispatcherImpl: dispatchEvent: {}", ev);
handler.processEvent(ev);
}
@Override
public void enqueueEvent(AbstractEvent event) {
if (event == null) {
+ logger.warn("enqueueEvent: event is null");
return;
}
try {
+ logger.info("EventDispatcherImpl: enqueueEvent: {}", event);
events.put(event);
} catch (InterruptedException e) {
logger.error("Thread was interrupted while trying to enqueue event ", e);