Attachment 878132 Details for Bug 1003674 – Reproducer/verifier

Reproducer/verifier

tst1003674.cpp (text/x-c++src), 1.98 KB, created by Ernie on 2014-03-24 17:37:17 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Ernie

Created: 2014-03-24 17:37:17 UTC

Size: 1.98 KB

patch

obsolete

>#include <qpid/messaging/Connection.h>
>#include <qpid/messaging/Message.h>
>#include <qpid/messaging/Receiver.h>
>#include <qpid/messaging/Sender.h>
>#include <qpid/messaging/Session.h>
>
>#include <qpid/framing/SequenceNumber.h>
>
>#include <iostream>
>#include <sstream>      // std::stringstream
>using namespace qpid::messaging;
>
>int seq = 0;
>void put(Session & session, Sender & sender, int i)
>{
>    Message msg;
>    std::stringstream ss;
>    for (int j=0; j<i; j++) {
>        ss.str(std::string());
>        ss << "Msg " << (++seq);
>        msg.setContent(ss.str());
>        sender.send(msg);
>    }
>}
>
>void get(Session & session, Receiver & receiver, int i)
>{
>    Message response;
>    std::string seqNo;
>    // capture errors without exiting
>    try {
>        for (int j=0; j<i; j++) {
>            response = receiver.fetch(Duration(1));
>
>            //session.acknowledge();
>            seqNo = response.getProperties()["queue_sequence"].asString();
>            std::cout << response.getContent() << " seqNo was " << seqNo << std::endl;
>        }
>    } catch(const std::exception& error) {
>        std::cerr << error.what() << std::endl;
>    }
>}
>
>int main(int argc, char** argv) {
>     std::string broker = argc > 1 ? argv[1] : "localhost:5672";
>     Connection connection(broker, "{protocol:amqp1.0}");
>
>     try {
>         connection.open();
>         Session session = connection.createSession();
>
>         std::string addr("my-queue;"
>                 " {create:sender,"
>                 " node: {type: queue, x-declare: {arguments:"
>                 " {qpid.queue_msg_sequence:queue_sequence}}}}");
>
>         Sender sender = session.createSender(addr);
>         Receiver receiver = session.createReceiver(addr);
>
>         // send messages 1, 2, and 3
>         put(session, sender, 3);
>         get(session, receiver, 3);
>
>         connection.close();
>         return 0;
>     } catch(const std::exception& error) {
>         std::cerr << error.what() << std::endl;
>         connection.close();
>         return 1;
>     }
> }

Actions: View

Attachments on bug 1003674: 878132