[07/10] incubator-ignite git commit: GG-9900 - Portable marshaller refactoring

[vkulichenko]

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f7f9e658/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
index 2e09ca8..a6a32c9 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerExecutionRequest.java
@@ -162,8 +162,8 @@ public class GridStreamerExecutionRequest implements 
Message {
 
         switch (writer.state()) {
             case 0:
-//                if (!writer.writeByteArray("batchBytes", batchBytes))
-//                    return false;
+                if (!writer.writeByteBuffer("batchBytes", batchBytes))
+                    return false;
 
                 writer.incrementState();
 
@@ -217,7 +217,7 @@ public class GridStreamerExecutionRequest implements 
Message {
 
         switch (reader.state()) {
             case 0:
-//                batchBytes = reader.readByteArray("batchBytes");
+                batchBytes = reader.readByteBuffer("batchBytes");
 
                 if (!reader.isLastRead())
                     return false;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f7f9e658/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
index fdaa002..6b47957 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/streamer/GridStreamerResponse.java
@@ -87,8 +87,8 @@ public class GridStreamerResponse implements Message {
 
         switch (writer.state()) {
             case 0:
-//                if (!writer.writeByteArray("errBytes", errBytes))
-//                    return false;
+                if (!writer.writeByteBuffer("errBytes", errBytes))
+                    return false;
 
                 writer.incrementState();
 
@@ -112,7 +112,7 @@ public class GridStreamerResponse implements Message {
 
         switch (reader.state()) {
             case 0:
-//                errBytes = reader.readByteArray("errBytes");
+                errBytes = reader.readByteBuffer("errBytes");
 
                 if (!reader.isLastRead())
                     return false;