Attachment 846765 Details for Bug 1049498 – reproducer

reproducer

sync_client.cpp (text/x-c++src), 1.19 KB, created by Petr Matousek on 2014-01-07 16:06:04 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Petr Matousek

Created: 2014-01-07 16:06:04 UTC

Size: 1.19 KB

patch

obsolete

>#include <qpid/messaging/Connection.h>
>#include <qpid/messaging/Session.h>
>
>#include <iostream>
>
>#include "OptionParser.h"
>
>using namespace qpid::messaging;
>
>struct Options : OptionParser
>{
>    std::string url;
>    std::string connectionOptions;
>
>    Options()
>        : OptionParser("Usage: sync_client [OPTIONS]", "bz reproducer"),
>          url("127.0.0.1")
>    {
>        add("broker,b", url, "url of broker to connect to");
>        add("connection-options", connectionOptions, "connection options string in the form {name1:value1, name2:value2}");
>    }
>};
>
>int main(int argc, char** argv)
>{
>    Options options;
>    if (options.parse(argc, argv)) {
>        Connection connection(options.url, options.connectionOptions);
>        try {
>            connection.open();
>            Session session;
>            session = connection.createSession();
>
>            while (connection.isOpen()) {
>                std::cerr << "syncing" << std::endl;
>                session.sync(true);
>                ::usleep(1000000);
>            }
>            return 0;
>        } catch(const std::exception& error) {
>            std::cerr << error.what() << std::endl;
>            connection.close();
>        }
>    }
>    return 1;
>}
>

Actions: View

Attachments on bug 1049498: 846765