This is an automated email from the ASF dual-hosted git repository.
robbie pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-jms.git
The following commit(s) were added to refs/heads/main by this push:
new 1fc1fdb QPIDJMS-557: gate log message on whether closure was already
requested
1fc1fdb is described below
commit 1fc1fdba0d56860cb2958f672954411902b8165b
Author: Robbie Gemmell <[email protected]>
AuthorDate: Mon Dec 20 11:55:33 2021 +0000
QPIDJMS-557: gate log message on whether closure was already requested
---
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: [email protected]
For additional commands, e-mail: [email protected]
