You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/09/12 15:59:25 UTC
[pulsar] branch master updated: Fix exception type check order bug
(#5174)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 81ccffc Fix exception type check order bug (#5174)
81ccffc is described below
commit 81ccffc8048f521613c670debcf54cb2a0b4e046
Author: Like <ke...@outlook.com>
AuthorDate: Thu Sep 12 23:59:18 2019 +0800
Fix exception type check order bug (#5174)
---
.../java/org/apache/pulsar/client/api/PulsarClientException.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
index bb681ad..db9c1fc 100644
--- a/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
+++ b/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java
@@ -231,12 +231,12 @@ public class PulsarClientException extends IOException {
return (PulsarClientException) t;
} else if (t instanceof RuntimeException) {
throw (RuntimeException) t;
+ } else if (t instanceof InterruptedException) {
+ Thread.currentThread().interrupt();
+ return new PulsarClientException(t);
} else if (!(t instanceof ExecutionException)) {
// Generic exception
return new PulsarClientException(t);
- } else if (t instanceof InterruptedException) {
- Thread.currentThread().interrupt();
- return new PulsarClientException(t);
}
// Unwrap the exception to keep the same exception type but a stack trace that includes the application calling