Attachment 619919 Details for Bug 804752 – Reproducer

Reproducer

main.cpp (text/x-c++src), 1.05 KB, created by Jason Dillaman on 2012-10-01 17:55:14 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Jason Dillaman

Created: 2012-10-01 17:55:14 UTC

Size: 1.05 KB

patch

obsolete

>#include <qpid/messaging/Connection.h>
>#include <qpid/messaging/Session.h>
>#include <qpid/messaging/Receiver.h>
>#include <qpid/types/Variant.h>
>#include <iostream>
>#include <boost/thread.hpp>
>#include <boost/bind.hpp>
>
>void thread(qpid::messaging::Connection connection, const std::string& queueName)
>{
>    qpid::messaging::Session session = connection.createSession();
>    qpid::messaging::Receiver receiver = session.createReceiver(queueName);
>    while (true) {
>        try {
>            while (session.nextReceiver(receiver, qpid::messaging::Duration::FOREVER)) {
>            }
>        }
>        catch (...) {
>        }
>    }
>}
>
>int main()
>{
>    qpid::types::Variant::Map options;
>    options["reconnect"] = true;
>    qpid::messaging::Connection connection("localhost", options);
>    connection.open();
>
>    boost::thread* thread1 = new boost::thread(boost::bind(thread, connection, "queue1"));
>    boost::thread* thread2 = new boost::thread(boost::bind(thread, connection, "queue2"));
>    thread1->join();
>    thread2->join();
>    connection.close(); 
>    return 0;
>}

Actions: View

Attachments on bug 804752: 619919 | 619924 | 636536 | 657325