mirror of https://github.com/zlatinb/muwire
add logging to event bus
parent
5407aa8616
commit
f2f09a359d
|
@ -4,11 +4,14 @@ import java.util.concurrent.CopyOnWriteArrayList
|
||||||
|
|
||||||
import com.muwire.core.files.FileSharedEvent
|
import com.muwire.core.files.FileSharedEvent
|
||||||
|
|
||||||
|
import groovy.util.logging.Log
|
||||||
|
@Log
|
||||||
class EventBus {
|
class EventBus {
|
||||||
|
|
||||||
private Map handlers = new HashMap()
|
private Map handlers = new HashMap()
|
||||||
|
|
||||||
void publish(Event e) {
|
void publish(Event e) {
|
||||||
|
log.fine "publishing event of type ${e.getClass().getSimpleName()}"
|
||||||
def currentHandlers
|
def currentHandlers
|
||||||
final def clazz = e.getClass()
|
final def clazz = e.getClass()
|
||||||
synchronized(handlers) {
|
synchronized(handlers) {
|
||||||
|
@ -20,6 +23,7 @@ class EventBus {
|
||||||
}
|
}
|
||||||
|
|
||||||
synchronized void register(Class<? extends Event> eventType, def handler) {
|
synchronized void register(Class<? extends Event> eventType, def handler) {
|
||||||
|
log.info "Registering $handler for type $eventType"
|
||||||
def currentHandlers = handlers.get(eventType)
|
def currentHandlers = handlers.get(eventType)
|
||||||
if (currentHandlers == null) {
|
if (currentHandlers == null) {
|
||||||
currentHandlers = new CopyOnWriteArrayList()
|
currentHandlers = new CopyOnWriteArrayList()
|
||||||
|
|
Loading…
Reference in New Issue