Attachment 625390 Details for Bug 853205 – reproducer script

reproducer script

bz853205.py (text/x-python), 1.41 KB, created by Leonid Zhaldybin on 2012-10-11 07:31:02 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Leonid Zhaldybin

Created: 2012-10-11 07:31:02 UTC

Size: 1.41 KB

patch

obsolete

>#!/usr/bin/python
>import sys
>from qpid.messaging import *
>import qmf.console
>
>if len(sys.argv) > 1:
>    q_name = str(sys.argv[1])
>else:
>    q_name = "test_q"
>
>sender_address = "%s; {create:always, node:{x-declare:{arguments:\
>{'qpid.priorities':10}},x-bindings:[{exchange:'amq.fanout',queue:%s}]}}" % \
>(q_name, q_name)
>
>broker_address = "localhost:5672"
>
>msg_number = 100
>
>connection = Connection(broker_address)
>connection.open()
>session = connection.session()
>
>s = session.sender(sender_address)
>
># send messages with different priorities
>for m in xrange(msg_number): s.send(Message(str(m), priority=m%10))
>
># get Qmf handle for the queue
>qmf_session = qmf.console.Session()
>broker = qmf_session.addBroker()
>queues = qmf_session.getObjects(_class="queue", _package="org.apache.qpid.broker")
>queue = None
>for q in queues:
>    if q.name == q_name:
>	queue = q
>
># reroute messages
>queue.reroute(request=0, useAltExchange=False, exchange="amq.fanout", filter={})
>#queue.reroute(0, False, "amq.fanout", {})
>
>
># messages content in expected order
>expected = [str(10*i+p) for p in xrange(9,-1,-1) for i in xrange(0,10) ]
>
>r = session.receiver(q_name)
>messages = []
>for i in xrange(msg_number):
>    m = r.fetch()
>    session.acknowledge()
>    messages.append(m)
>
>qmf_session.delBroker(broker)
>connection.close()
>
>actual = [m.content for m in messages]
>
>if actual == expected:
>    print "test PASSED"
>    exit(0)
>else:
>    print "test FAILED"
>    exit(1)

Actions: View

Attachments on bug 853205: 625390