Initial testing.

1 files changed, 36 insertions, 0 deletions

diff --git a/loginfo-consumer b/loginfo-consumer
new file mode 100755
index 0000000..e146711
--- /dev/null
+++ b/loginfo-consumer
@@ -0,0 +1,36 @@
+#!/usr/bin/python
+# -*- mode: python; coding: utf-8 -*-
+
+from qpid.util import connect
+from qpid.connection import Connection
+from qpid.datatypes import Message, RangedSet, uuid4
+from qpid.queue import Empty
+
+from lxml import etree
+
+host = '127.0.0.1'
+port = 5672
+
+socket = connect(host, port)
+connection = Connection (sock=socket)
+connection.start()
+session = connection.session(str(uuid4()))
+
+local_queue_name = 'local_queue'
+local_queue = session.incoming(local_queue_name)
+
+session.message_subscribe(queue = 'loginfo_queue', destination = local_queue_name)
+local_queue.start()
+
+message = None
+while True:
+    try:
+	message = local_queue.get()
+        session.message_accept(RangedSet(message.id))
+	root_element = etree.fromstring(message.body)
+	print etree.tostring(root_element, pretty_print=True)
+    except Empty:
+        print 'No more messages!'
+        break
+
+session.close(timeout=10)