Skip to content

Commit 72259b7

Browse files
committed
Enh 37137606 - ENH: Improve proxy log message to include serializer type mismatch between the server and client.
(auto-submit 112347 after successfully running remote remote.full) Job ID: job.9.20250106163326.19842 [git-p4: depot-paths = "//dev/coherence-ce/main/": change = 113235]
1 parent 62a0a90 commit 72259b7

File tree

1 file changed

+12
-11
lines changed
  • prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service

1 file changed

+12
-11
lines changed

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/Peer.java

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2000, 2024, Oracle and/or its affiliates.
2+
* Copyright (c) 2000, 2025, Oracle and/or its affiliates.
33
*
44
* Licensed under the Universal Permissive License v 1.0 as shown at
55
* https://oss.oracle.com/licenses/upl.
@@ -1804,8 +1804,8 @@ public void onMessage(com.tangosol.net.messaging.Message message)
18041804
message.run();
18051805
}
18061806

1807-
/**
1808-
* Called when an exception occurs during Message decoding. This method is
1807+
/**
1808+
* Called when an exception occurs during Message decoding. This method is
18091809
* called on the service thread.
18101810
*
18111811
* @param e the Throwable thrown during decoding
@@ -1815,13 +1815,13 @@ public void onMessage(com.tangosol.net.messaging.Message message)
18151815
* configured WrapperStreamFactory objects
18161816
*
18171817
* @see #onNotify
1818-
*/
1818+
*/
18191819
protected void onMessageDecodeException(Throwable e, com.tangosol.io.ReadBuffer.BufferInput in, com.tangosol.coherence.component.net.extend.Connection connection, boolean fFilter)
18201820
{
18211821
// import Component.Net.Extend.Channel;
18221822
// import Component.Net.Extend.Connection;
18231823
// import java.io.IOException;
1824-
1824+
18251825
// resolve the Channel
18261826
Channel channel;
18271827
try
@@ -1833,7 +1833,7 @@ protected void onMessageDecodeException(Throwable e, com.tangosol.io.ReadBuffer.
18331833
}
18341834
channel = (Channel) connection.getChannel(in.readPackedInt());
18351835
}
1836-
catch (IOException ee)
1836+
catch (IOException ioe)
18371837
{
18381838
channel = null;
18391839
}
@@ -1845,13 +1845,14 @@ protected void onMessageDecodeException(Throwable e, com.tangosol.io.ReadBuffer.
18451845

18461846
if (channel != null)
18471847
{
1848-
sb.append(" This service is configured with a serializer: ")
1848+
sb.append(String.format(" This service is using serializer \"%s\": ", channel.getSerializer().getName()))
18491849
.append(channel.getSerializer())
1850-
.append(", which may be incompatible with the serializer configured by the connecting client.");
1850+
.append(", which is different or incompatible with the serializer being used by the connecting client.")
1851+
.append(String.format(" Please ensure connecting client is using the same serializer as the one configured for this service"));
18511852
}
1852-
1853+
18531854
_trace(e, sb.toString());
1854-
1855+
18551856
// close the Channel or Connection
18561857
if (channel == null || !channel.isOpen() || channel.getId() == 0)
18571858
{
@@ -1862,7 +1863,7 @@ protected void onMessageDecodeException(Throwable e, com.tangosol.io.ReadBuffer.
18621863
channel.close(true, e);
18631864
}
18641865
}
1865-
1866+
18661867
/**
18671868
* Called when an exception occurs during Message encoding. This method is
18681869
* called on both client and service threads.

0 commit comments

Comments
 (0)