kombu/examples/simple_send.py

"""

Example that sends a single message and exits using the simple interface.

You can use `simple_receive.py` (or `complete_receive.py`) to receive the
message sent.

"""
from __future__ import with_statement

from kombu import BrokerConnection

#: Create connection
#: If hostname, userid, password and virtual_host is not specified
#: the values below are the default, but listed here so it can
#: be easily changed.
with BrokerConnection("amqp://guest:guest@localhost:5672//") as conn:

    #: SimpleQueue mimics the interface of the Python Queue module.
    #: First argument can either be a queue name or a kombu.Queue object.
    #: If a name, then the queue will be declared with the name as the queue
    #: name, exchange name and routing key.
    with conn.SimpleQueue("kombu_demo") as queue:
        queue.put({"hello": "world"}, serializer="json", compression="zlib")


#####
# If you don't use the with statement, you must always
# remember to close objects.
#   queue.close()
#   connection.close()