= pn_message();
pn_messenger_get(msgConsumer, message);
.
.
pn_message_free(message);
}
pn_link_close(link);
From: Dominic Evans [via Qpid]
[mailto:ml-node+s2158936n7617738...@n2.nabble.com]
Sent: jeudi 18 décembre 2014 17:44
To: Millieret, Xavier
Subject: RE: CorrelationId
xavier wrote
Perhaps I must
158936.n2.nabble.com/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.
sage);
.
.
pn_message_free(message);
}
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 msgCons
message is arrived
pn_message_t* message = pn_message();
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.
m: Dominic Evans [via Qpid]
[mailto:ml-node+s2158936n7617327...@n2.nabble.com]
Sent: mercredi 10 décembre 2014 12:07
To: Millieret, Xavier
Subject: Re: CorrelationId
Hi Xavier, so 006FE360 is your messenger that is responsible for subscribing
and receiving the messages based upon the selector.
xa
ot;com.eaton.pqsoft","uuid":"c1b3e315-a5e4-47b
> 4-8128-51b0bf6284b7","timeStamp":1418208069,"providerId":"emc4j","flowType":"reply","destination":"TestSimpleBus.add","contentType":"jav
reply","destination":"TestSimpleBus.add","contentType":"java.lang.Integer
"},"body":18}"
[02B82D30]:0 -> @transfer(20) [handle=0, delivery-id=1,
delivery-tag=b"\x01\x00\x00\x00\x00\x00\x00\x00", message-format=0,
settled=true, more=false]
(405)
"\x00Sp\xd0\x00\x00\x00\x0b\x00\x00\x00\x05BP\x04@BR\x00\x00Ss\xd0\x00\x00\x00\x86\x00\x00\x00\x0d@@\xa1+amqp://localhost:5672/queue://TestSimpl
eBus@\xa1\x0bemc2-ea2a65\xa1$3d28790d-1a5d-49d5-36d9-e0bd143a97fe\xa3\x06string@\x83\x00\x00\x00\x00\x00\x00\x00\x00\x83\x00\x00\x00\x00\x00\x00\x00\x
00@R\x00@\x00Sw\xa1\xef{"header":{"manufacturer":"com.eaton.pqsoft","uuid":"c3046674-4e25-775f-d043-ecf657cf33ca","timeStamp":1418208081.919,"provider
Id":"emc2-ea2a65","flowType":"request","destination":"TestSimpleBus.add","bodyType":null},"body":{"a":10,"b":8}}"
2014/12/10-11:42:48.581 | AmqpMessageBusTransport | ERROR : Timeout
reached on the get synchronous reply, 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.
ks a lot
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7617311.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
just accepting those that you are interested in via
correl 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.
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
i am lost with this
library!!
Thanks
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7616320.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
ssenger_subscribe to allow you to specify a
> filter
> up-front before the first attach.
>
Yes, or equivalently add a pn_subscription_set_filter to allow the returned
subscription 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 mailing list archive at Nabble.com.
>
er specific? Either
way I expect that the broker will expect it be sent as part of the initial
@attach. You *could* try modifying the pn_data_t returned by
pn_terminus_filter and then doing a pn_link_close immediately followed by a
pn_link_open.
Alternatively extend pn_messenger_subscribe to allow you t
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
Hi all,
Thanks a lot for your answer, I am busy today, but I will try this, and send
you me feedback.
Regards
--
View this message in context:
http://qpid.2158936.n2.nabble.com/CorrelationId-tp7614606p7614825.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
);
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
es_t bytes = pn_bytes(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);
>>
>&g
, 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_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
isn't 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.nabb
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-tp7614606p7614740.html
rhaps someone with more knowledge can comment.
Robbie
On 2 October 2014 15:44, xavier 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:
se
October 2014 15:44, xavier 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(destin
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 +
&
25 matches
Mail list logo
