You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/09/07 11:17:12 UTC
[27/50] [abbrv] ignite git commit: WIP
WIP
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/629b75ed
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/629b75ed
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/629b75ed
Branch: refs/heads/ignite-2649
Commit: 629b75ed28e3538565b45b64fa4de8ccc26df8fa
Parents: db8a8b6
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Wed Sep 7 12:11:50 2016 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Wed Sep 7 12:11:50 2016 +0300
----------------------------------------------------------------------
.../main/java/org/apache/ignite/stream/socket/SocketStreamer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/629b75ed/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java b/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java
index 1e79e1c..fd2b037 100644
--- a/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java
+++ b/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java
@@ -231,7 +231,7 @@ public class SocketStreamer<T, K, V> extends StreamAdapter<T, K, V> {
/** {@inheritDoc} */
@Override public T convert(byte[] msg) {
try {
- return MarshallerUtils.unmarshal(gridName, marsh, msg, null);
+ return marsh.unmarshal(msg, null);
}
catch (IgniteCheckedException e) {
throw new IgniteException(e);