Denis,
Yes, this is not supported now, because user doesn't know the underlying
cache name. Here is the ticket:
https://issues.apache.org/jira/browse/IGNITE-1144
-Val
On Thu, Jan 28, 2016 at 2:12 AM, Denis Magda <dma...@gridgain.com> wrote:
> Igniteres,
>
> Seems that the documentation contains a wrong example on how it's possible
> to drain a collocated queue [1].
>
> According to it, this can be easily done by sending a closure on a node
> that holds it
>
> // Drain queue on the node where the queue is cached.
> ignite.compute().affinityRun("cacheName","queueName",queuePoller);
>
>
> However, in my understanding this is incorrect information cause such an
> approach won't work.
>
> Can anybody comment on this? Do we have any ticket that will allow to add
> an ability for draining of collocated queues?
>
> [1] https://apacheignite.readme.io/docs/queue-and-set#bounded-queues
>
> --
> Denis
>
