ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [1/2] incubator-ignite git commit: GG-10507 all works
Date Wed, 08 Jul 2015 14:23:26 GMT
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 <ptupitsyn@gridgain.com>
Authored: Wed Jul 8 17:12:28 2015 +0300
Committer: Pavel Tupitsyn <ptupitsyn@gridgain.com>
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);


Mime
View raw message