# gg-9791 - Communication fixes
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/86b233c9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/86b233c9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/86b233c9 Branch: refs/heads/ignite-185 Commit: 86b233c9ecf27ed88880231d983e823af5f819d1 Parents: ae9df45 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Thu Feb 19 20:42:41 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Thu Feb 19 20:42:41 2015 -0800 ---------------------------------------------------------------------- .../managers/communication/GridIoMessageFactory.java | 12 +++++++++--- .../plugin/extensions/communication/MessageAdapter.java | 7 +++++++ 2 files changed, 16 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/86b233c9/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java index ec74b7f..65cd774 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java @@ -68,13 +68,19 @@ public class GridIoMessageFactory implements MessageFactory { switch (type) { case TcpCommunicationSpi.NODE_ID_MSG_TYPE: - return new TcpCommunicationSpi.NodeIdMessage(); + msg = new TcpCommunicationSpi.NodeIdMessage(); + + break; case TcpCommunicationSpi.RECOVERY_LAST_ID_MSG_TYPE: - return new TcpCommunicationSpi.RecoveryLastReceivedMessage(); + msg = new TcpCommunicationSpi.RecoveryLastReceivedMessage(); + + break; case TcpCommunicationSpi.HANDSHAKE_MSG_TYPE: - return new TcpCommunicationSpi.HandshakeMessage(); + msg = new TcpCommunicationSpi.HandshakeMessage(); + + break; case 0: msg = new GridJobCancelRequest(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/86b233c9/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java index 807bda5..6f0a73a 100644 --- a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java @@ -65,6 +65,13 @@ public abstract class MessageAdapter implements Serializable { public abstract byte directType(); /** + * Gets fields count. + * + * @return Fields count. + */ + public abstract byte fieldsCount(); + + /** * Defines whether recovery for this message should be skipped. * * @return Whether recovery for this message should be skipped.
