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: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
|