'Forward disconnection to all consumers.'

def disconnect(self, message, **kwargs):

    for (stream, consumer) in self.consumers.items():
        kwargs['multiplexer'] = self.multiplexer_class(stream, self.message.reply_channel)
        consumer(message, **kwargs)
