# coding:utf8

# __author:  Administrator

# date:      //

# /usr/bin/env python

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(

    host='localhost'

))

channel = connection.channel()

channel.exchange_declare(exchange='topic_logs',

                         type='topic')

key = 'ha.ga.ef'

message='Hello World'

channel.basic_publish(exchange='topic_logs',

                      routing_key=key,

                      body=message)

print("Sent message")

connection.close()

# coding:utf8

# __author:  Administrator

# date:      //

# /usr/bin/env python

import pika

import sys

connection = pika.BlockingConnection(pika.ConnectionParameters(

    host='localhost'

))

channel = connection.channel()

channel.exchange_declare(exchange='topic_logs',

                         type='topic')

result = channel.queue_declare(exclusive=True)

queue_name = result.method.queue

bind_key = 'ha'

channel.queue_bind(exchange='topic_logs',

                   queue=queue_name,

                   routing_key=bind_key)

print('Wait for logs')

def callback(ch, method, properties, body):

    print(body)

channel.basic_consume(callback,

                      queue=queue_name,

                      no_ack=True)

channel.start_consuming()