/CorrelationId-tp7614606p7617738.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Hi,
Any body have an idea about this? The new version of the lib will fix this,
or it's my code?
regards
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7617531.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
, queue: emc2-ea2a65
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7617326.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
.
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7617327.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
();
pn_messenger_get(msgConsumer, message);
.
.
pn_message_free(message);
}
pn_link_close(link);
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7617333.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
);
}
pn_link_close(link);
The goal is simple, why I implemented this, because I implemented the pattern
request/reply, and the reply is in function of the correlationid (setted in the
request), so in my application I have the msgConsumer builds one time, and I
reuse it each time, that I wait the reply
id
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7617293.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
.nabble.com/CorrelationId-tp7614606p7617311.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Hi all,
I found the solution (for ActiveMq, with a connector in AMQP, and a
connector with openwire), so I share the solution.
I used the idea of Dominic Evans, so If I want to get a message from a
filter (for example correlationId ), I did this:
pn_messenger_t* msgConsumer= pn_messenger(NULL
:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7616320.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Hi all,
pn_messenger_get_link is not in the 0.7 qpid lib, right?
Is it in the next release 0.8 ? If yes do you have any date for it, and code
sample, with?
Thanks a lot
regards
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7614826.html
Sent
pn_messenger_subscribe to allow you to specify a filter
up-front before the first attach.
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7614830.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
to be modified. It should be pretty straightforward to do
either one. I haven't had time personally but I would welcome the
contribution. ;-)
--Rafael
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7614830.html
Sent from the Apache Qpid Proton
it
pn_messenger_put(messengerProducer, message);
I see on the broker, the correlationId is correctly setted, so no pb.
after I wait the answer, but I would like (like JMS) only wake up on an
answer at my question (and the correlationId is here to do that)
in CMS
MessageConsumer* consumer = session
, id);
and after, send it
pn_messenger_put(messengerProducer, message);
I see on the broker, the correlationId is correctly setted, so no pb.
after I wait the answer, but I would like (like JMS) only wake up on an
answer at my question (and the correlationId is here to do that)
in CMS
);
pn_atom_t id;
id.type = PN_STRING;
id.u.as_bytes = bytes;
pn_message_set_correlation_id(message, id);
and after, send it
pn_messenger_put(messengerProducer, message);
I see on the broker, the correlationId is correctly setted, so no pb.
after I wait the answer, but I would like (like JMS) only
(correlationId.size(), corrId);
pn_atom_t id;
id.type = PN_STRING;
id.u.as_bytes = bytes;
pn_message_set_correlation_id(message, id);
and after, send it
pn_messenger_put(messengerProducer, message);
I see on the broker, the correlationId is correctly setted, so no pb.
after I wait the answer
temporally queue? or using selector
(in messenger), but I don't know (with the documentation), how it's works?
is there any sample?
Thanks a lot for your help
Regards
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7614740.html
Sent from the Apache
it? So to do that must I take some temporally queue? or using selector
(in messenger), but I don't know (with the documentation), how it's works?
is there any sample?
Thanks a lot for your help
Regards
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId
October 2014 15:44, xavier xaviermillie...@eaton.com wrote:
Hi all,
I am new with Qpid Proton So I try to using it with ActiveMq, and
migrate my old code based on CMS (JMS for C) ! I would like to get a
message
filtered on correlationId, like with CMS:
session-createConsumer(destination
Hi all,
I am new with Qpid Proton So I try to using it with ActiveMq, and
migrate my old code based on CMS (JMS for C) ! I would like to get a message
filtered on correlationId, like with CMS:
session-createConsumer(destination, JMSCorrelationID=' + correlationId +
')
But with Qpid proton
21 matches
Mail list logo
