Attachment 712879 Details for Bug 923397 – part of reproducer

part of reproducer

example2.cpp (text/x-c++src), 2.52 KB, created by Gordon Sim on 2013-03-19 18:18:01 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Gordon Sim

Created: 2013-03-19 18:18:01 UTC

Size: 2.52 KB

patch

obsolete

>#include <qpid/client/Connection.h>
>#include <qpid/client/Session.h>
>#include <qpid/client/Message.h>
>#include <qpid/client/MessageListener.h>
>#include <qpid/client/SubscriptionManager.h>
>
>#include <cstdlib>
>#include <iostream>
>
>using namespace qpid::client;
>
>struct Listener : MessageListener
>{
>    void received(Message&);
>    bool process(Message&);
>    Subscription subscription;
>};
>
>bool Listener::process(Message& message)
>{
>    std::cout << "Process message '" << message.getData() 
>              << "'? Enter Y or N" << std::endl;
>    std::string response;
>    while (std::cin >> response) {
>        if (response == "Y" || response == "y") {
>            return true;
>        } else if (response == "N" || response == "n") {
>            return false;
>        }
>        std::cout << "Please enter 'Y' or 'N'" << std::endl;
>    }
>    subscription.cancel();
>    return false;
>}
>
>void Listener::received(Message& message)
>{
>    //In this example messages are delivered unacquired and we only
>    //try to acquire if we can process it.
>    if (process(message)) {
>        //Now try to acquire message. If the acquisition is successful
>        //the message id will be moved from the unacquired set into
>        //the unaccepted set.
>        subscription.acquire(message);
>        if (subscription.getUnaccepted().contains(message.getId())) {
>            subscription.accept(message);
>        } else { 
>            std::cout << "Message no longer available for acquisition: " << message.getData() << std::endl;
>        }
>    }
>}
>
>int main(int argc, char** argv)
>{
>    const char* host = argc>1 ? argv[1] : "127.0.0.1";
>    int port = argc>2 ? atoi(argv[2]) : 5672;
>
>    Connection connection;
>    try {
>        connection.open(host, port);
>        Session session = connection.newSession();
>        SubscriptionManager subMgr(session);
>        
>        SubscriptionSettings settings(FlowControl::messageWindow(1));
>        //Turn off the automatic 'acknowledgement' of received
>        //messages:
>        settings.autoAck = 0;
>
>        //Set the acquire mode to 'not-acquired'; this means received
>        //message are not acquired; i.e. they remain available for
>        //other subscribers:
>        settings.acquireMode = ACQUIRE_MODE_NOT_ACQUIRED;
>
>        Listener listener;
>        session.queueDeclare(arg::queue="message-queue");
>        listener.subscription = subMgr.subscribe(listener, "message-queue", settings);
>        subMgr.run();
>
>        session.close();
>    } catch(const std::exception& error) {
>        std::cout << error.what() << std::endl;
>    }        
>}

Actions: View

Attachments on bug 923397: 712879