In our case we're only using the receiver as you describe, to update the key that it was invoked for. Our actual use case is that the incoming stream of data sometimes sends us old data, which we want to discard rather than cache. So the StreamReceiver examines the value already in the cache and either applies the update or discards it. I re-examined our code, and it only operates on keys that were supplied in the second arg to the receive() function (the Collection<Entry<K, V>> of updated entries).
>From your description it seems like this should be safe, and yet it seems to be hitting a deadlock somewhere... -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
