[1/9] incubator-ignite git commit: Revert "ignite-nio - Removing message clone"

[vkulichenko]

Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-nio 5085e4681 -> 35e64ef29


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/01689b1d/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
index 38f8e9c..16e2327 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/collision/jobstealing/JobStealingRequest.java
@@ -59,7 +59,7 @@ public class JobStealingRequest extends MessageAdapter {
         writer.setBuffer(buf);
 
         if (!writer.isTypeWritten()) {
-            if (!writer.writeMessageType(directType()))
+            if (!writer.writeByte(null, directType()))
                 return false;
 
             writer.onTypeWritten();
@@ -67,7 +67,7 @@ public class JobStealingRequest extends MessageAdapter {
 
         switch (writer.state()) {
             case 0:
-                if (!writer.writeField("delta", delta, MessageFieldType.INT))
+                if (!writer.writeInt("delta", delta))
                     return false;
 
                 writer.incrementState();
@@ -83,7 +83,7 @@ public class JobStealingRequest extends MessageAdapter {
 
         switch (readState) {
             case 0:
-                delta = reader.readField("delta", MessageFieldType.INT);
+                delta = reader.readInt("delta");
 
                 if (!reader.isLastRead())
                     return false;