IGNITE-27831 Java thin: Refactor ReliableChannel - Fixes #12733.

Signed-off-by: Aleksey Plekhanov <plehanov.alex@gmail.com>

Author: alex-plekhanov

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientAtomicLongImpl.java

@@ -35,7 +35,7 @@ public class ClientAtomicLongImpl implements ClientAtomicLong {
     private final String groupName;
 
     /** */
-    private final ReliableChannel ch;
+    private final ReliableChannelEx ch;
 
     /** Cache id. */
     private final int cacheId;
@@ -47,7 +47,7 @@ public class ClientAtomicLongImpl implements ClientAtomicLong {
      * @param groupName Cache group name.
      * @param ch Channel.
      */
-    public ClientAtomicLongImpl(String name, @Nullable String groupName, ReliableChannel ch) {
+    public ClientAtomicLongImpl(String name, @Nullable String groupName, ReliableChannelEx ch) {
         // name and groupName uniquely identify the data structure.
         this.name = name;
         this.groupName = groupName;

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientCacheEntryListenerHandler.java

@@ -53,7 +53,7 @@ public class ClientCacheEntryListenerHandler<K, V> implements NotificationListen
     private final Cache<K, V> jCacheAdapter;
 
     /** */
-    private final ReliableChannel ch;
+    private final ReliableChannelEx ch;
 
     /** */
     private final boolean keepBinary;
@@ -76,7 +76,7 @@ public class ClientCacheEntryListenerHandler<K, V> implements NotificationListen
     /** */
     ClientCacheEntryListenerHandler(
         Cache<K, V> jCacheAdapter,
-        ReliableChannel ch,
+        ReliableChannelEx ch,
         ClientBinaryMarshaller marsh,
         boolean keepBinary
     ) {

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientClusterGroupImpl.java

@@ -56,7 +56,7 @@
  */
 class ClientClusterGroupImpl implements ClientClusterGroup {
     /** Channel. */
-    protected final ReliableChannel ch;
+    protected final ReliableChannelEx ch;
 
     /** Marshaller utils. */
     protected final ClientUtils utils;
@@ -79,7 +79,7 @@ class ClientClusterGroupImpl implements ClientClusterGroup {
     /**
      *
      */
-    ClientClusterGroupImpl(ReliableChannel ch, ClientBinaryMarshaller marsh) {
+    ClientClusterGroupImpl(ReliableChannelEx ch, ClientBinaryMarshaller marsh) {
         this.ch = ch;
 
         utils = new ClientUtils(marsh);
@@ -90,7 +90,7 @@ class ClientClusterGroupImpl implements ClientClusterGroup {
     /**
      *
      */
-    private ClientClusterGroupImpl(ReliableChannel ch, ClientUtils utils,
+    private ClientClusterGroupImpl(ReliableChannelEx ch, ClientUtils utils,
         ProjectionFilters projectionFilters) {
         this.ch = ch;
         this.utils = utils;

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientClusterImpl.java

@@ -33,7 +33,7 @@ public class ClientClusterImpl extends ClientClusterGroupImpl implements ClientC
     /**
      * Constructor.
      */
-    ClientClusterImpl(ReliableChannel ch, ClientBinaryMarshaller marsh) {
+    ClientClusterImpl(ReliableChannelEx ch, ClientBinaryMarshaller marsh) {
         super(ch, marsh);
 
         dfltClusterGrp = (ClientClusterGroupImpl)forServers();

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientComputeImpl.java

@@ -57,7 +57,7 @@ class ClientComputeImpl implements ClientCompute {
     private static final byte NO_RESULT_CACHE_FLAG_MASK = 0x02;
 
     /** Channel. */
-    private final ReliableChannel ch;
+    private final ReliableChannelEx ch;
 
     /** Utils for serialization/deserialization. */
     private final ClientUtils utils;
@@ -69,7 +69,7 @@ class ClientComputeImpl implements ClientCompute {
     private final AtomicInteger tasksCnt = new AtomicInteger();
 
     /** Constructor. */
-    ClientComputeImpl(ReliableChannel ch, ClientBinaryMarshaller marsh, ClientClusterGroupImpl dfltGrp) {
+    ClientComputeImpl(ReliableChannelEx ch, ClientBinaryMarshaller marsh, ClientClusterGroupImpl dfltGrp) {
         this.ch = ch;
         this.dfltGrp = dfltGrp;
 

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientFieldsQueryPager.java

@@ -40,7 +40,7 @@ class ClientFieldsQueryPager extends GenericQueryPager<List<?>> implements Field
 
     /** Constructor. */
     ClientFieldsQueryPager(
-        ReliableChannel ch,
+        ReliableChannelEx ch,
         @Nullable TcpClientTransaction tx,
         ClientOperation qryOp,
         ClientOperation pageQryOp,
@@ -59,7 +59,7 @@ class ClientFieldsQueryPager extends GenericQueryPager<List<?>> implements Field
 
     /** Constructor. */
     ClientFieldsQueryPager(
-        ReliableChannel ch,
+        ReliableChannelEx ch,
         @Nullable TcpClientTransaction tx,
         ClientOperation qryOp,
         ClientOperation pageQryOp,

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientIgniteSetImpl.java

@@ -43,7 +43,7 @@ class ClientIgniteSetImpl<T> implements ClientIgniteSet<T> {
     private final String name;
 
     /** */
-    private final ReliableChannel ch;
+    private final ReliableChannelEx ch;
 
     /** */
     private final ClientUtils serDes;
@@ -69,7 +69,7 @@ class ClientIgniteSetImpl<T> implements ClientIgniteSet<T> {
      * @param cacheId Cache id.
      */
     public ClientIgniteSetImpl(
-            ReliableChannel ch,
+            ReliableChannelEx ch,
             ClientUtils serDes,
             String name,
             boolean colocated,

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientQueryPager.java

@@ -36,7 +36,7 @@ class ClientQueryPager<K, V> extends GenericQueryPager<Cache.Entry<K, V>> {
 
     /** Constructor. */
     ClientQueryPager(
-        ReliableChannel ch,
+        ReliableChannelEx ch,
         @Nullable TcpClientTransaction tx,
         ClientOperation qryOp,
         ClientOperation pageQryOp,
@@ -53,7 +53,7 @@ class ClientQueryPager<K, V> extends GenericQueryPager<Cache.Entry<K, V>> {
 
     /** Constructor. */
     ClientQueryPager(
-        ReliableChannel ch,
+        ReliableChannelEx ch,
         @Nullable TcpClientTransaction tx,
         ClientOperation qryOp,
         ClientOperation pageQryOp,

modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientServicesImpl.java

@@ -57,7 +57,7 @@ class ClientServicesImpl implements ClientServices {
     static final int SRV_TOP_UPDATE_PERIOD = 60_000;
 
     /** Channel. */
-    private final ReliableChannel ch;
+    private final ReliableChannelImpl ch;
 
     /** Binary marshaller. */
     private final ClientBinaryMarshaller marsh;
@@ -75,7 +75,7 @@ class ClientServicesImpl implements ClientServices {
     private final Map<String, ServiceTopology> servicesTopologies;
 
     /** Constructor. */
-    ClientServicesImpl(ReliableChannel ch, ClientBinaryMarshaller marsh, ClientClusterGroupImpl grp, IgniteLogger log) {
+    ClientServicesImpl(ReliableChannelImpl ch, ClientBinaryMarshaller marsh, ClientClusterGroupImpl grp, IgniteLogger log) {
         this.ch = ch;
         this.marsh = marsh;
         this.grp = grp;

modules/core/src/main/java/org/apache/ignite/internal/client/thin/GenericQueryPager.java

@@ -39,7 +39,7 @@ abstract class GenericQueryPager<T> implements QueryPager<T> {
     private final Consumer<PayloadOutputChannel> qryWriter;
 
     /** Channel. */
-    private final ReliableChannel ch;
+    private final ReliableChannelEx ch;
 
     /** Client Transaction. */
     private final @Nullable TcpClientTransaction tx;
@@ -64,7 +64,7 @@ abstract class GenericQueryPager<T> implements QueryPager<T> {
 
     /** Constructor. */
     GenericQueryPager(
-        ReliableChannel ch,
+        ReliableChannelEx ch,
         @Nullable TcpClientTransaction tx,
         ClientOperation qryOp,
         ClientOperation pageQryOp,
@@ -83,7 +83,7 @@ abstract class GenericQueryPager<T> implements QueryPager<T> {
 
     /** Constructor. */
     GenericQueryPager(
-        ReliableChannel ch,
+        ReliableChannelEx ch,
         @Nullable TcpClientTransaction tx,
         ClientOperation qryOp,
         ClientOperation pageQryOp,