Attachment 593419 Details for Bug 834256 – test reproducer

test reproducer

bz693444_test.cpp (text/x-c++src), 1.67 KB, created by Petr Matousek on 2012-06-21 11:07:40 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Petr Matousek

Created: 2012-06-21 11:07:40 UTC

Size: 1.67 KB

patch

obsolete

>#include <iostream>
>#include <boost/format.hpp>
>#include <qpid/messaging/Connection.h>
>#include <qpid/messaging/Session.h>
>#include <qpid/messaging/Message.h>
>#include <qpid/messaging/Sender.h>
>#include <qpid/messaging/Receiver.h>
>#include <qpid/messaging/exceptions.h>
>#include <assert.h>
>
>using namespace std;
>using namespace qpid::messaging;
>using namespace boost;
>
>int main(int argc, char* argv[])
>{
>    try
>    {
>        Connection conn("localhost:5672");
>        conn.open();
>        Session sess1 = conn.createSession();
>        Session sess2 = conn.createSession();
>
>        Sender tx = sess1.createSender("amq.direct/key");
>        Receiver rx_main = sess1.createReceiver("amq.direct/key;{link:{reliability:at-least-once, x-declare:{alternate-exchange:'amq.fanout'}}}");
>        Receiver rx_alt = sess2.createReceiver("amq.fanout");
>        rx_alt.setCapacity(10);
>
>        tx.send(Message("DATA"));
>        tx.send(Message("DATA"));
>        tx.send(Message("DATA"));
>        tx.send(Message("DATA"));
>        tx.send(Message("DATA"));
>
>        rx_main.fetch();
>        rx_main.fetch();
>        rx_main.fetch();
>
>        assert(rx_alt.getAvailable()==0 || cout << rx_alt.getAvailable() <<\
>          " != 0 Assertion fail" << "No messages should have been routed to" <<\
>          " the alt_exchange" << endl);
>
>
>        sess1.close();
>        sleep(1);
>
>        assert(rx_alt.getAvailable()==5 || cout << rx_alt.getAvailable() <<\
>          " != 5 Assertion fail, All 5 messages should have been routed to" <<\
>          " the alt_exchange" << endl);
>
>        sess2.close();
>
>        conn.close();
>    } 
>
>    catch(MessagingException& e)
>    {
>      cerr << e.what() << endl;
>    }
>
>    return 0;
>}
>

Actions: View

Attachments on bug 834256: 593419