(pulsar) branch branch-4.0 updated: [fix] Prevent IllegalStateException: Field 'message' is not set (#24472)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.0 by this push:
     new 46f60195af0 [fix] Prevent IllegalStateException: Field 'message' is 
not set (#24472)
46f60195af0 is described below

commit 46f60195af026b6f2876f08a1b81ba844ab99c34
Author: Andrey Yegorov <8622884+dl...@users.noreply.github.com>
AuthorDate: Wed Jul 2 08:57:02 2025 -0700

    [fix] Prevent IllegalStateException: Field 'message' is not set (#24472)
---
 .../src/main/java/org/apache/pulsar/client/impl/ClientCnx.java      | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
index d32ab213648..a5829df64f2 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
@@ -648,10 +648,12 @@ public class ClientCnx extends PulsarHandler {
             if (!lookupResult.hasResponse()
                     || 
CommandLookupTopicResponse.LookupType.Failed.equals(lookupResult.getResponse()))
 {
                 if (lookupResult.hasError()) {
-                    checkServerError(lookupResult.getError(), 
lookupResult.getMessage());
+                    checkServerError(lookupResult.getError(),
+                            lookupResult.hasMessage() ? 
lookupResult.getMessage() : lookupResult.getError().name());
                     requestFuture.completeExceptionally(
                             getPulsarClientException(lookupResult.getError(),
-                                    buildError(lookupResult.getRequestId(), 
lookupResult.getMessage())));
+                                    buildError(lookupResult.getRequestId(),
+                                            lookupResult.hasMessage() ? 
lookupResult.getMessage() : null)));
                 } else {
                     requestFuture
                             .completeExceptionally(new 
PulsarClientException.LookupException("Empty lookup response"));