http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxEntryValueHolder.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxEntryValueHolder.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxEntryValueHolder.java index 5845ebd..4c41e21 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxEntryValueHolder.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/TxEntryValueHolder.java @@ -222,7 +222,7 @@ public class TxEntryValueHolder implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(TxEntryValueHolder.class); } /** {@inheritDoc} */
http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheRawVersionedEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheRawVersionedEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheRawVersionedEntry.java index 9a14d9b..86a9b1b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheRawVersionedEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheRawVersionedEntry.java @@ -307,7 +307,7 @@ public class GridCacheRawVersionedEntry<K, V> extends DataStreamerEntry implemen assert key != null; assert !(val != null && valBytes != null); - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridCacheRawVersionedEntry.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java index 602bded..a72c5c2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersion.java @@ -326,7 +326,7 @@ public class GridCacheVersion implements Message, Comparable<GridCacheVersion>, } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridCacheVersion.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersionEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersionEx.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersionEx.java index 901b7d9..5e848d5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersionEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/version/GridCacheVersionEx.java @@ -137,7 +137,7 @@ public class GridCacheVersionEx extends GridCacheVersion { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridCacheVersionEx.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java index 0364cb0..23bc179 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaSnapshotMessage.java @@ -126,7 +126,7 @@ public class GridClockDeltaSnapshotMessage implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridClockDeltaSnapshotMessage.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java index c14214b..941a1fa 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/clock/GridClockDeltaVersion.java @@ -165,7 +165,7 @@ public class GridClockDeltaVersion implements Message, Comparable<GridClockDelta } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridClockDeltaVersion.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java index 966f5a0..e521a0c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousMessage.java @@ -248,7 +248,7 @@ public class GridContinuousMessage implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridContinuousMessage.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerEntry.java index 95ad316..7eadb04 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerEntry.java @@ -150,7 +150,7 @@ public class DataStreamerEntry implements Map.Entry<KeyCacheObject, CacheObject> } - return reader.afterMessageRead(null); + return reader.afterMessageRead(DataStreamerEntry.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java index 0f2fa09..fa08b7b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java @@ -466,7 +466,7 @@ public class DataStreamerRequest implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(DataStreamerRequest.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerResponse.java index f557bfb..e753e32 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerResponse.java @@ -151,7 +151,7 @@ public class DataStreamerResponse implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(DataStreamerResponse.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java index 0023e73..b551b7b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsAckMessage.java @@ -177,7 +177,7 @@ public class IgfsAckMessage extends IgfsCommunicationMessage { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsAckMessage.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java index fe487b7..efb84d4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlockKey.java @@ -240,7 +240,7 @@ public final class IgfsBlockKey implements Message, Externalizable, Comparable<I } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsBlockKey.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java index 4343170..120745c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsBlocksMessage.java @@ -158,7 +158,7 @@ public class IgfsBlocksMessage extends IgfsCommunicationMessage { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsBlocksMessage.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java index 309daf1..c2c24ca 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsCommunicationMessage.java @@ -69,7 +69,7 @@ public abstract class IgfsCommunicationMessage implements Message { if (!reader.beforeMessageRead()) return false; - return true; + return reader.afterMessageRead(IgfsCommunicationMessage.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java index c1d1ee2..8656745 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsDeleteMessage.java @@ -167,7 +167,7 @@ public class IgfsDeleteMessage extends IgfsCommunicationMessage { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsDeleteMessage.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java index 9ca363d..d18ea82 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileAffinityRange.java @@ -56,6 +56,9 @@ public class IgfsFileAffinityRange implements Message, Externalizable { /** Range end offset (endOff + 1 divisible by block size). */ private long endOff; + /** Field kept for backward compatibility. */ + private boolean done; + /** * Empty constructor required by {@link Externalizable}. */ @@ -265,7 +268,7 @@ public class IgfsFileAffinityRange implements Message, Externalizable { case 1: // The field 'done' was removed, but its writing preserved for compatibility reasons. - if (!writer.writeBoolean("done", false)) + if (!writer.writeBoolean("done", done)) return false; writer.incrementState(); @@ -311,7 +314,7 @@ public class IgfsFileAffinityRange implements Message, Externalizable { case 1: // field 'done' was removed, but reading preserved for compatibility reasons. - reader.readBoolean("done"); + done = reader.readBoolean("done"); if (!reader.isLastRead()) return false; @@ -344,7 +347,7 @@ public class IgfsFileAffinityRange implements Message, Externalizable { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsFileAffinityRange.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java index 1d3974d..cf657e3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerRequest.java @@ -139,7 +139,7 @@ public class IgfsFragmentizerRequest extends IgfsCommunicationMessage { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsFragmentizerRequest.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java index b65e1c3..6dd7534 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFragmentizerResponse.java @@ -101,7 +101,7 @@ public class IgfsFragmentizerResponse extends IgfsCommunicationMessage { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsFragmentizerResponse.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java index e0bb267..60b56ac 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsSyncMessage.java @@ -132,7 +132,7 @@ public class IgfsSyncMessage extends IgfsCommunicationMessage { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(IgfsSyncMessage.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryCancelRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryCancelRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryCancelRequest.java index fb5d0ee..e679ed4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryCancelRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryCancelRequest.java @@ -99,7 +99,7 @@ public class GridQueryCancelRequest implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridQueryCancelRequest.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryFailResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryFailResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryFailResponse.java index d8aa319..6fd607c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryFailResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryFailResponse.java @@ -125,7 +125,7 @@ public class GridQueryFailResponse implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridQueryFailResponse.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageRequest.java index fff3173..8e95ab8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageRequest.java @@ -152,7 +152,7 @@ public class GridQueryNextPageRequest implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridQueryNextPageRequest.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageResponse.java index 48ae011..d06e118 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryNextPageResponse.java @@ -29,6 +29,7 @@ import java.util.*; /** * Next page response. */ +@IgniteCodeGeneratingFail public class GridQueryNextPageResponse implements Message { /** */ private static final long serialVersionUID = 0L; @@ -268,7 +269,7 @@ public class GridQueryNextPageResponse implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridQueryNextPageResponse.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryRequest.java index d8f8da3..2b04c52 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/messages/GridQueryRequest.java @@ -31,6 +31,7 @@ import java.util.*; /** * Query request. */ +@IgniteCodeGeneratingFail public class GridQueryRequest implements Message { /** */ private static final long serialVersionUID = 0L; @@ -294,7 +295,7 @@ public class GridQueryRequest implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridQueryRequest.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java index e37e7bd..951b1e0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultRequest.java @@ -153,7 +153,7 @@ public class GridTaskResultRequest implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridTaskResultRequest.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java index 4be06ed..d29c525 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/task/GridTaskResultResponse.java @@ -199,7 +199,7 @@ public class GridTaskResultResponse implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridTaskResultResponse.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java index d026c5b..83939c0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridByteArrayList.java @@ -461,7 +461,7 @@ public class GridByteArrayList implements Message, Externalizable { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridByteArrayList.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java index c8bd588..1711f03 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLongList.java @@ -559,7 +559,7 @@ public class GridLongList implements Message, Externalizable { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(GridLongList.class); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/ignite/blob/86e3b27f/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 a93b4de..8b95149 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 @@ -95,7 +95,7 @@ public class JobStealingRequest implements Message { } - return reader.afterMessageRead(null); + return reader.afterMessageRead(JobStealingRequest.class); } /** {@inheritDoc} */
