diff --git a/exchange/exchange.go b/exchange/exchange.go index 1854e55..7ba759d 100644 --- a/exchange/exchange.go +++ b/exchange/exchange.go @@ -29,7 +29,7 @@ func (ex *Exchange) Listen(event string, fn func(interface{})) { func (ex *Exchange) Send(event string, data interface{}) { ex.mtx.RLock() for _, fn := range ex.queues[event] { - fn(data) + go fn(data) } ex.mtx.RUnlock() }