Added ttl exampels

examples/consume_queue_until_empty.py

@@ -2,7 +2,7 @@
 
 from amqpstorm import Connection
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 
 def consume_until_queue_is_empty():

examples/create_queue_with_a_ttl_on_messages.py

@@ -0,0 +1,27 @@
+import logging
+
+from amqpstorm import Connection
+from amqpstorm import Message
+
+logging.basicConfig(level=logging.INFO)
+
+
+def publish_message(channel, body, queue):
+    # Create a message.
+    message = Message.create(channel, body)
+
+    # Publish the message to a queue.
+    message.publish(queue)
+
+
+if __name__ == '__main__':
+    with Connection('127.0.0.1', 'guest', 'guest') as CONNECTION:
+        with CONNECTION.channel() as CHANNEL:
+            # Declare the Queue, 'simple_queue' with a message ttl of 6000ms.
+            CHANNEL.queue.declare('simple_ttl_queue', arguments={
+                'x-message-ttl': 6000,
+            })
+
+            # Publish the message to a queue called, 'simple_queue' with an
+            # expiration set to 6000ms.
+            publish_message(CHANNEL, 'Hello World', 'simple_ttl_queue')

examples/publish_message_with_expiration.py

@@ -0,0 +1,26 @@
+import logging
+
+from amqpstorm import Connection
+from amqpstorm import Message
+
+logging.basicConfig(level=logging.INFO)
+
+
+def publish_message(channel, body, queue, expiration="600"):
+    # Create the message with a expiration (time to live).
+    message = Message.create(channel, body,
+                             properties={"expiration": expiration})
+
+    # Publish the message to a queue.
+    message.publish(queue)
+
+
+if __name__ == '__main__':
+    with Connection('127.0.0.1', 'guest', 'guest') as CONNECTION:
+        with CONNECTION.channel() as CHANNEL:
+            # Declare the Queue, 'simple_queue'.
+            CHANNEL.queue.declare('simple_queue')
+
+            # Publish the message to a queue called, 'simple_queue' with an
+            # expiration set to 6000ms.
+            publish_message(CHANNEL, 'Hello World', 'simple_queue', "6000")

examples/robust_consumer.py

@@ -7,7 +7,7 @@
 import amqpstorm
 from amqpstorm import Connection
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 LOGGER = logging.getLogger()
 

examples/scalable_consumer.py

@@ -8,7 +8,7 @@
 import amqpstorm
 from amqpstorm import Connection
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 LOGGER = logging.getLogger()
 
 

examples/scalable_rpc_server.py

@@ -9,7 +9,7 @@
 from amqpstorm import Connection
 from amqpstorm import Message
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 LOGGER = logging.getLogger()
 

examples/simple_consumer.py

@@ -2,7 +2,7 @@
 
 from amqpstorm import Connection
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 
 def on_message(message):

examples/simple_generator_consumer.py

@@ -2,7 +2,7 @@
 
 from amqpstorm import Connection
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 
 def start_consumer():

examples/simple_publisher.py

@@ -3,7 +3,7 @@
 from amqpstorm import Connection
 from amqpstorm import Message
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 
 def publish_message():

examples/simple_transaction_publisher.py

@@ -3,7 +3,7 @@
 from amqpstorm import Connection
 from amqpstorm import Message
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 
 def publish_messages():

examples/ssl_with_context.py

@@ -3,7 +3,7 @@
 
 from amqpstorm import Connection
 
-logging.basicConfig(level=logging.DEBUG)
+logging.basicConfig(level=logging.INFO)
 
 
 def on_message(message):