In order to distinguish between multiple consumers on the same channel the consumer-tag must be saved and used to check when we are emitting the messages to the message-supply.
This may also fix #10 but it materialised when I was making a test for Queue.bind where a tap for a previously deleted queue continued to get mesages (this correctly breaking the tests).
In order to distinguish between multiple consumers on the same channel the consumer-tag must be saved and used to check when we are emitting the messages to the message-supply.
This may also fix #10 but it materialised when I was making a test for Queue.bind where a tap for a previously deleted queue continued to get mesages (this correctly breaking the tests).