'Forward connection to all consumers.'

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

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