Menu Search

list_agents.cpp

#include <qpid/messaging/Connection.h>
#include <qpid/messaging/Duration.h>
#include <qmf/ConsoleSession.h>
#include <qmf/ConsoleEvent.h>
#include <qmf/Agent.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();

    session.setAgentFilter("");

    while (true) {
        ConsoleEvent event;
        if (session.nextEvent(event)) {
            if (event.getType() == CONSOLE_AGENT_ADD) {
                string extra;
                if (event.getAgent().getName() == session.getConnectedBrokerAgent().getName())
                    extra = "  [Connected Broker]";
                cout << "Agent Added: " << event.getAgent().getName() << extra << endl;
            }
            if (event.getType() == CONSOLE_AGENT_DEL) {
                if (event.getAgentDelReason() == AGENT_DEL_AGED)
                    cout << "Agent Aged: " << event.getAgent().getName() << endl;
                else
                    cout << "Agent Filtered: " << event.getAgent().getName() << endl;
            }
        }
    }
}

Download this file