Artem,
Do AMQP subscribers subscribe to a cursor (i.e. cursor and pn_link are 1
to 1)? If so, you probably have some data structure that represents the
subscription. This data structure holds references to the proton link
and the cursor. I don't know how your program is structured, so I can't
comment in too much detail. Are you familiar with the reactive
programming model?
-Ted
On 07/08/2016 03:33 PM, Artem wrote:
Ted,
Please describe how the data should be send to consumer function when onData
function is invoked?(if this function have a link, and i do the
Sender.send(message) whether there is a transfer messages in transport and
write to socket?)
Artem
--
View this message in context:
http://qpid.2158936.n2.nabble.com/Broker-with-live-data-tp7647047p7647127.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
