ClientReconnectMessage id shouldn't be saved for lastMsgId on client side
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a563ba05 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a563ba05 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a563ba05 Branch: refs/heads/ignite-3477-master Commit: a563ba0556d940cc3665973b6098758786db72c1 Parents: 6bb4c81 Author: Sergey Chugunov <[email protected]> Authored: Wed Apr 12 13:41:09 2017 +0300 Committer: Sergey Chugunov <[email protected]> Committed: Thu Apr 13 12:48:36 2017 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a563ba05/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java index 6c7c220..34ee414 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java @@ -1842,7 +1842,9 @@ class ClientImpl extends TcpDiscoveryImpl { spi.stats.onMessageProcessingFinished(msg); - if (spi.ensured(msg) && state == CONNECTED) + if (spi.ensured(msg) + && state == CONNECTED + && !(msg instanceof TcpDiscoveryClientReconnectMessage)) lastMsgId = msg.id(); }
