Attachment 863747 Details for Bug 1059786 – Reproducer

Reproducer

acquire_message_and_disconnect.cpp (text/x-c++src), 974 bytes, created by Pavel Moravec on 2014-02-16 14:25:34 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2014-02-16 14:25:34 UTC

Size: 974 bytes

patch

obsolete

>#include <qpid/messaging/Address.h>
>#include <qpid/messaging/Connection.h>
>#include <qpid/messaging/Receiver.h>
>#include <qpid/messaging/Sender.h>
>#include <qpid/messaging/Session.h>
>#include <qpid/messaging/Message.h>
>#include <iostream>
>
>using namespace std;
>using namespace qpid::messaging;
>
>int main(int argc, char ** argv)
>{
>    string queue="q; {create: always}";
>    string broker="127.0.0.1:5672";
>    if (argc > 1)
>        queue=argv[1];
>    if (argc > 2)
>        broker=argv[2];
>    for (unsigned i=0; i<2; i++)
>    {
>        Connection connection = Connection(broker, "{protocol : 'amqp1.0'}");
>        connection.open();
>        Session session = connection.createSession();
>        if (i==0)
>            session.createSender(queue).send(Message());
>        Receiver receiver = session.createReceiver(queue);
>        Message msg = receiver.fetch();
>        cout << "Properties: " << msg.getProperties() << endl;
>        connection.close();
>    }
>    return 0;
>}

Actions: View

Attachments on bug 1059786: 863747 | 863748