GG-10507 Need to add StreamReceiver to .NET
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/90580d8f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/90580d8f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/90580d8f Branch: refs/heads/ignite-890 Commit: 90580d8ff47b4f2a56b794c2a8596d0f9db28310 Parents: bee6f68 Author: Pavel Tupitsyn <ptupit...@gridgain.com> Authored: Thu Jul 9 21:18:10 2015 +0300 Committer: Pavel Tupitsyn <ptupit...@gridgain.com> Committed: Thu Jul 9 21:18:10 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/datastreamer/DataStreamProcessor.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/90580d8f/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java index 9e53bb5..54478f8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java @@ -255,6 +255,9 @@ public class DataStreamProcessor<K, V> extends GridProcessorAdapter { try { updater = marsh.unmarshal(req.updaterBytes(), clsLdr); + + if (updater != null) + ctx.resource().injectGeneric(updater); } catch (IgniteCheckedException e) { U.error(log, "Failed to unmarshal message [nodeId=" + nodeId + ", req=" + req + ']', e);
