summaryrefslogtreecommitdiff
path: root/java/client/src
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2006-11-07 12:23:43 +0000
committerMartin Ritchie <ritchiem@apache.org>2006-11-07 12:23:43 +0000
commit252facc9ed32b421ff20e02950ad6834ebbaea52 (patch)
tree10bb5a02df8fbc410049b5c359d8030b77f44e4a /java/client/src
parentfd15e4036bc07dbe9430e45bd900de2fcbd01ba2 (diff)
downloadqpid-python-252facc9ed32b421ff20e02950ad6834ebbaea52.tar.gz
Added extra logging around InVM failures
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472081 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
-rw-r--r--java/client/src/org/apache/qpid/client/transport/TransportConnection.java26
1 files changed, 24 insertions, 2 deletions
diff --git a/java/client/src/org/apache/qpid/client/transport/TransportConnection.java b/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
index c935ff0ad0..a7ca3ffc3c 100644
--- a/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
+++ b/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
@@ -219,7 +219,18 @@ public class TransportConnection
{
_logger.info("Unable to create InVM Qpid.AMQP on port " + port + ". Because: " + e.getCause());
_logger.error(e);
- throw new AMQVMBrokerCreationException(port, e.getCause() + " Stopped InVM Qpid.AMQP creation");
+ String because;
+ if (e.getCause() == null)
+ {
+ because = e.toString();
+ }
+ else
+ {
+ because = e.getCause().toString();
+ }
+
+
+ throw new AMQVMBrokerCreationException(port, because + " Stopped InVM Qpid.AMQP creation");
}
_acceptor.bind(pipe, provider);
@@ -230,7 +241,18 @@ public class TransportConnection
catch (IOException e)
{
_logger.error(e);
- throw new AMQVMBrokerCreationException(port, e.getCause() + " Stopped binding of InVM Qpid.AMQP");
+
+ String because;
+ if (e.getCause() == null)
+ {
+ because = e.toString();
+ }
+ else
+ {
+ because = e.getCause().toString();
+ }
+
+ throw new AMQVMBrokerCreationException(port, because + " Stopped binding of InVM Qpid.AMQP");
}
}
else