The interface is slightly weird. If I call Sub() twice (e.g. in two different goroutines) for the same queue, each message will be received by one of these two

The interface is slightly weird. If I call Sub() twice (e.g. in two different goroutines) for the same queue, each message will be received by one of these two subscribers (because the channel is shared). I'd expect exact opposite: all of them to receive each message.