1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
# -*- coding: utf-8 -*-
# pylint: disable=C0111,C0103,R0205
import logging
import pika
from pika import DeliveryMode
from pika.exchange_type import ExchangeType
logging.basicConfig(level=logging.DEBUG)
credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters('localhost', credentials=credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.exchange_declare(exchange="test_exchange",
exchange_type=ExchangeType.direct,
passive=False,
durable=True,
auto_delete=False)
print("Sending message to create a queue")
channel.basic_publish(
'test_exchange', 'standard_key', 'queue:group',
pika.BasicProperties(content_type='text/plain',
delivery_mode=DeliveryMode.Transient))
connection.sleep(5)
print("Sending text message to group")
channel.basic_publish(
'test_exchange', 'group_key', 'Message to group_key',
pika.BasicProperties(content_type='text/plain',
delivery_mode=DeliveryMode.Transient))
connection.sleep(5)
print("Sending text message")
channel.basic_publish(
'test_exchange', 'standard_key', 'Message to standard_key',
pika.BasicProperties(content_type='text/plain',
delivery_mode=DeliveryMode.Transient))
connection.close()
|
