[
https://issues.apache.org/jira/browse/QPID-5594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13918020#comment-13918020
]
ASF subversion and git services commented on QPID-5594:
-------------------------------------------------------
Commit 1573546 from [~pmoravec] in branch 'qpid/trunk'
[ https://svn.apache.org/r1573546 ]
QPID-5594: [amqp1.0] missing first-acquirer property support in C++ broker
> [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
> Labels: easyfix, easytest, patch
> 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: [email protected]
For additional commands, e-mail: [email protected]
