mirror of https://github.com/celery/kombu.git
33 lines
1.2 KiB
Python
33 lines
1.2 KiB
Python
"""
|
|
|
|
Example producer that sends a single message and exits.
|
|
|
|
You can use `complete_receive.py` to receive the message sent.
|
|
|
|
"""
|
|
from __future__ import with_statement
|
|
|
|
from kombu import Connection, Exchange, Queue
|
|
|
|
#: By default messages sent to exchanges are persistent (delivery_mode=2),
|
|
#: and queues and exchanges are durable.
|
|
exchange = Exchange("kombu_demo", type="direct")
|
|
queue = Queue("kombu_demo", exchange, routing_key="kombu_demo")
|
|
|
|
|
|
with Connection("amqp://guest:guest@localhost:5672//") as connection:
|
|
|
|
#: Producers are used to publish messages.
|
|
#: a default exchange and routing key can also be specifed
|
|
#: as arguments the Producer, but we rather specify this explicitly
|
|
#: at the publish call.
|
|
producer = connection.Producer()
|
|
|
|
#: Publish the message using the json serializer (which is the default),
|
|
#: and zlib compression. The kombu consumer will automatically detect
|
|
#: encoding, serializiation and compression used and decode accordingly.
|
|
producer.publish({"hello": "world"},
|
|
exchange=exchange,
|
|
routing_key="kombu_demo",
|
|
serializer="json", compression="zlib")
|