import pika

connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.exchange_declare(exchange='logs', exchange_type='fanout') #transmissão das mensagens para todas
                                                                  #as filas conhecidas
result = channel.queue_declare(queue='', exclusive=True) #{ parâmetro 'queue' vazio faz com que o server
                                                         #determine um nome aleatório para a fila
queue_name = result.method.queue_declare                 #o atributo 'exclusive' determina que a fila deve
                                                         #ser excluída quando o 'consumer' é fechado }
channel.queue_bind(exchange='logs', queue=queue_name) 

print(' [*] Waiting for logs. To exit press CTRL+C')

def callback(ch, method, properties, body):
   print(" [x] %r" % body)

channel.basic_consume(
   queue=queue_name, on_message_callback=callback, auto_ack=True)

channel.start_consuming()
32ac023bc60b688d698617196545d419b07f714f
<mask token>

<mask token>
channel.exchange_declare(exchange='logs', exchange_type='fanout')
<mask token>
channel.queue_bind(exchange='logs', queue=queue_name)
print(' [*] Waiting for logs. To exit press CTRL+C')


def callback(ch, method, properties, body):
    print(' [x] %r' % body)


channel.basic_consume(queue=queue_name, on_message_callback=callback,
    auto_ack=True)
channel.start_consuming()

<mask token>
connection = pika.BlockingConnection(pika.ConnectionParameters(host=
    'localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='logs', exchange_type='fanout')
result = channel.queue_declare(queue='', exclusive=True)
queue_name = result.method.queue_declare
channel.queue_bind(exchange='logs', queue=queue_name)
print(' [*] Waiting for logs. To exit press CTRL+C')


def callback(ch, method, properties, body):
    print(' [x] %r' % body)


channel.basic_consume(queue=queue_name, on_message_callback=callback,
    auto_ack=True)
channel.start_consuming()

import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host=
    'localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='logs', exchange_type='fanout')
result = channel.queue_declare(queue='', exclusive=True)
queue_name = result.method.queue_declare
channel.queue_bind(exchange='logs', queue=queue_name)
print(' [*] Waiting for logs. To exit press CTRL+C')


def callback(ch, method, properties, body):
    print(' [x] %r' % body)


channel.basic_consume(queue=queue_name, on_message_callback=callback,
    auto_ack=True)
channel.start_consuming()

import pika

connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.exchange_declare(exchange='logs', exchange_type='fanout') #transmissão das mensagens para todas
                                                                  #as filas conhecidas
result = channel.queue_declare(queue='', exclusive=True) #{ parâmetro 'queue' vazio faz com que o server
                                                         #determine um nome aleatório para a fila
queue_name = result.method.queue_declare                 #o atributo 'exclusive' determina que a fila deve
                                                         #ser excluída quando o 'consumer' é fechado }
channel.queue_bind(exchange='logs', queue=queue_name) 

print(' [*] Waiting for logs. To exit press CTRL+C')

def callback(ch, method, properties, body):
   print(" [x] %r" % body)

channel.basic_consume(
   queue=queue_name, on_message_callback=callback, auto_ack=True)

channel.start_consuming()