memory transport example (#627)

1 files changed, 24 insertions, 0 deletions

diff --git a/examples/memory_transport.py b/examples/memory_transport.py
new file mode 100644
index 00000000..f0b43940
--- /dev/null
+++ b/examples/memory_transport.py
@@ -0,0 +1,24 @@
+"""
+Example that use memory transport for message produce.
+"""
+import time
+
+from kombu import Connection, Exchange, Queue, Consumer
+
+media_exchange = Exchange('media', 'direct')
+video_queue = Queue('video', exchange=media_exchange, routing_key='video')
+task_queues = [video_queue]
+
+
+def handle_message(body, message):
+    print("%s RECEIVED MESSAGE: %r" % (time.time(), body))
+    message.ack()
+
+
+connection = Connection("memory:///")
+consumer = Consumer(connection, task_queues, callbacks=[handle_message])
+
+producer = connection.Producer(serializer='json')
+producer.publish({"foo": "bar"}, exchange=media_exchange, routing_key='video', declare=task_queues)
+consumer.consume()
+connection.drain_events()