Index: wildfly/wildfly-integration/src/main/java/org/teiid/replication/jgroups/JGroupsObjectReplicator.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git a/wildfly/wildfly-integration/src/main/java/org/teiid/replication/jgroups/JGroupsObjectReplicator.java b/wildfly/wildfly-integration/src/main/java/org/teiid/replication/jgroups/JGroupsObjectReplicator.java
--- a/wildfly/wildfly-integration/src/main/java/org/teiid/replication/jgroups/JGroupsObjectReplicator.java	(revision f002cdb65d4d41573e0ee4272d797dd1f80b53a2)
+++ b/wildfly/wildfly-integration/src/main/java/org/teiid/replication/jgroups/JGroupsObjectReplicator.java	(date 1623768220877)
@@ -520,6 +520,7 @@
         methodMap.put(finishState, (short)(methodList.size() - 1));
 
         ReplicatedInvocationHandler<S> proxy = new ReplicatedInvocationHandler<S>(object, methodMap);
+        channel.setReceiver(proxy);
         /*
          * TODO: could have an object implement streaming
          * Override the normal handle method to support streaming
Index: wildfly/wildfly-integration/src/main/java/org/teiid/jboss/JGroupsObjectReplicatorService.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
diff --git a/wildfly/wildfly-integration/src/main/java/org/teiid/jboss/JGroupsObjectReplicatorService.java b/wildfly/wildfly-integration/src/main/java/org/teiid/jboss/JGroupsObjectReplicatorService.java
--- a/wildfly/wildfly-integration/src/main/java/org/teiid/jboss/JGroupsObjectReplicatorService.java	(revision f002cdb65d4d41573e0ee4272d797dd1f80b53a2)
+++ b/wildfly/wildfly-integration/src/main/java/org/teiid/jboss/JGroupsObjectReplicatorService.java	(date 1623768220867)
@@ -41,8 +41,7 @@
             @Override
             public JChannel createChannel(String id) throws Exception {
                 JChannel c = channelFactoryInjector.getValue().createChannel(id);
-                 c.connect(id);
-                 return c;
+                return c;
             }
         }, executorInjector.getValue());
     }