diff options
Diffstat (limited to 'qpid/java/common/src')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java | 10 | ||||
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java | 5 |
2 files changed, 6 insertions, 9 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java index 245f12ad0b..890aeda11b 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java @@ -537,16 +537,16 @@ public class Connection extends ConnectionInvoker connectionLost.set(true); synchronized (lock) { - log.error(e, "exception: %s", e.getMessage()); + if(log.isDebugEnabled()) + { + log.debug("exception: %s state : %s", e.getMessage(), state); + } switch (state) { case OPENING: case CLOSING: - if (error == null) - { - error = e; - } + error = e; lock.notifyAll(); return; } diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java index 8e1395aa83..1bbf166d82 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java @@ -187,10 +187,7 @@ public class SSLReceiver implements Receiver<ByteBuffer> } catch(SSLException e) { - if (log.isDebugEnabled()) - { - log.debug(e, "Error caught in SSLReceiver"); - } + log.error(e, "Error caught in SSLReceiver"); _sslStatus.setSslErrorFlag(); synchronized(_sslStatus.getSslLock()) { |