'Forward messages to all consumers.'

def receive(self, content, **kwargs):

    if (isinstance(content, dict) and ('stream' in content) and ('payload' in content)):
        for (stream, consumer) in self.consumers.items():
            if (stream == content['stream']):
                payload = content['payload']
                if (not isinstance(payload, dict)):
                    raise ValueError('Multiplexed    frame    payload    is    not    a    dict')
                self.message.content['text'] = self.encode_json(payload)
                kwargs['multiplexer'] = self.multiplexer_class(stream, self.message.reply_channel)
                if hasattr(consumer, 'send'):
                    consumer.send = self.send
                consumer(self.message, **kwargs)
                return
        raise ValueError('Invalid    multiplexed    frame    received    (stream    not    mapped)')
    else:
        raise ValueError('Invalid    multiplexed    **frame    received    (no    channel/payload    key)')
