Repository: incubator-ignite Updated Branches: refs/heads/ignite-gg-10507 [created] da1249f57
GG-10507 all works Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/775fe24f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/775fe24f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/775fe24f Branch: refs/heads/ignite-gg-10507 Commit: 775fe24fb8a53d6e2cbeb96fd67382fb55da4208 Parents: 6d6ec77 Author: Pavel Tupitsyn <[email protected]> Authored: Wed Jul 8 17:12:28 2015 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Wed Jul 8 17:12:28 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/datastreamer/DataStreamProcessor.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/775fe24f/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..81f4776 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,10 @@ public class DataStreamProcessor<K, V> extends GridProcessorAdapter { try { updater = marsh.unmarshal(req.updaterBytes(), clsLdr); + + // TODO: think. Lifecycle iface? + if (updater != null) + ctx.resource().injectGeneric(updater); } catch (IgniteCheckedException e) { U.error(log, "Failed to unmarshal message [nodeId=" + nodeId + ", req=" + req + ']', e);
