search

rinq / rinq-go

A cross-language command bus and distributed ephemeral data store.
Other
17 stars 1 forks source link

Execute multicast notifications handlers in separate goroutines. #74

Open jmalloc opened 7 years ago

jmalloc commented 7 years ago

notifyamqp.listener currently uses one goroutine per AMQP message, but handlers for the same message should execute concurrently.

jmalloc commented 7 years ago

One goroutine per-session would probably be best.

jmalloc commented 6 years ago

Leaving this as is, users can synchronise as necessary using channels/mutexes.

jmalloc commented 6 years ago

One goroutine per-session would probably be best.

Reopened, mostly because this ^^ is necessary to guarantee consistent notification delivery order.