qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Pavel Moravec (JIRA)" <j...@apache.org>
Subject [jira] [Created] (QPID-5594) [amqp1.0] missing first-acquirer property support in C++ broker
Date Mon, 03 Mar 2014 12:41:23 GMT
Pavel Moravec created QPID-5594:
-----------------------------------

             Summary: [amqp1.0] missing first-acquirer property support in C++ broker
                 Key: QPID-5594
                 URL: https://issues.apache.org/jira/browse/QPID-5594
             Project: Qpid
          Issue Type: Bug
          Components: C++ Broker
    Affects Versions: 0.24
            Reporter: Pavel Moravec
            Assignee: Pavel Moravec
            Priority: Minor
             Fix For: 0.27


Description of problem:

There is a defined standard amqp1.0 property: first-acquirer. The broker shall support setting
this property accordingly.

If this value is true, then this message has not been acquired by any other link. If this
value is false, then this message MAY have previously been acquired by another link or links.

Version-Release number of selected component (if applicable):
qpid-cpp-*-0.22-33

How reproducible:
100%

Steps to Reproduce:
compile and run program:

#include <qpid/messaging/Address.h>
#include <qpid/messaging/Connection.h>
#include <qpid/messaging/Receiver.h>
#include <qpid/messaging/Sender.h>
#include <qpid/messaging/Session.h>
#include <qpid/messaging/Message.h>
#include <iostream>

using namespace std;
using namespace qpid::messaging;

int main(int argc, char ** argv)
{
    string queue="q; {create: always}";
    string broker="127.0.0.1:5672";
    if (argc > 1)
        queue=argv[1];
    if (argc > 2)
        broker=argv[2];
    for (unsigned i=0; i<2; i++)
    {
        Connection connection = Connection(broker, "{protocol : 'amqp1.0'}");
        connection.open();
        Session session = connection.createSession();
        if (i==0)
            session.createSender(queue).send(Message());
        Receiver receiver = session.createReceiver(queue);
        Message msg = receiver.fetch();
        cout << "Properties: " << msg.getProperties() << endl;
        connection.close();
    }
    return 0;
}



Actual results:
first-acquirer property is not set by the broker

Expected results:
first-acquirer property is set to true by the broker in the first message, and unset (or set
to false) in the second message

Additional info:



--
This message was sent by Atlassian JIRA
(v6.2#6252)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org


Mime
View raw message