You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2021/12/20 17:06:31 UTC
[qpid-jms] 01/03: QPIDJMS-557: gate log message on whether closure was already requested
This is an automated email from the ASF dual-hosted git repository.
robbie pushed a commit to branch 0.x
in repository https://gitbox.apache.org/repos/asf/qpid-jms.git
commit 94c3b59299708b4a3997f0781d57306f0c55c0eb
Author: Robbie Gemmell <ro...@apache.org>
AuthorDate: Mon Dec 20 11:55:33 2021 +0000
QPIDJMS-557: gate log message on whether closure was already requested
(cherry picked from commit 1fc1fdba0d56860cb2958f672954411902b8165b)
---
qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
index 4a1edfa..4fcdefd 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
@@ -1375,7 +1375,9 @@ public class JmsConnection implements AutoCloseable, Connection, TopicConnection
public void onConnectionFailure(final ProviderException ex) {
providerFailed(ex);
- LOG.warn("Connection {} has failed due to: {}", connectionInfo.getId(), ex != null ? ex.getMessage() : "No error details provided.");
+ if (!closing.get() && !closed.get()) {
+ LOG.warn("Connection {} has failed due to: {}", connectionInfo.getId(), ex != null ? ex.getMessage() : "No error details provided.");
+ }
// Signal that connection dropped we need to mark transactions as
// failed, deliver failure events to asynchronous send completions etc.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org