Menu Search

print_events.cpp

#include <qpid/messaging/Connection.h>
#include <qpid/messaging/Duration.h>
#include <qmf/ConsoleSession.h>
#include <qmf/ConsoleEvent.h>
#include <qmf/Data.h>
#include <qpid/types/Variant.h>
#include <string>
#include <iostream>

using namespace std;
using namespace qmf;
using qpid::types::Variant;
using qpid::messaging::Duration;

int main(int argc, char** argv)
{
    string url("localhost");
    string connectionOptions;
    string sessionOptions;

    if (argc > 1)
        url = argv[1];
    if (argc > 2)
        connectionOptions = argv[2];
    if (argc > 3)
        sessionOptions = argv[3];

    qpid::messaging::Connection connection(url, connectionOptions);
    connection.open();

    ConsoleSession session(connection, sessionOptions);
    session.open();

    while (true) {
        ConsoleEvent event;
        if (session.nextEvent(event)) {
            if (event.getType() == CONSOLE_EVENT) {
                const Data& data(event.getData(0));
                cout << "Event: timestamp=" << event.getTimestamp() << " severity=" <<
                    event.getSeverity() << " content=" << data.getProperties() << endl;
            }
        }
    }
}

Download this file