You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2006/11/07 12:32:43 UTC
svn commit: r472069 -
/incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
Author: ritchiem
Date: Tue Nov 7 03:32:41 2006
New Revision: 472069
URL: http://svn.apache.org/viewvc?view=rev&rev=472069
Log:
Added extra logging around InVM failures
Modified:
incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
Modified: incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java?view=diff&rev=472069&r1=472068&r2=472069
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java Tue Nov 7 03:32:41 2006
@@ -114,7 +114,17 @@
public IoConnector newSocketConnector()
{
SocketConnector result;
- result = new SocketConnector(); // non-blocking connector
+ //FIXME - this needs to be sorted to use the new Mina MultiThread SA.
+ if (Boolean.getBoolean("qpidnio"))
+ {
+ _logger.warn("Using Qpid NIO - DISABLED");
+// result = new org.apache.qpid.nio.SocketConnector(); // non-blocking connector
+ }
+// else
+ {
+ _logger.warn("Using Mina NIO");
+ result = new SocketConnector(); // non-blocking connector
+ }
// Don't have the connector's worker thread wait around for other connections (we only use
// one SocketConnector per connection at the moment anyway). This allows short-running
@@ -198,9 +208,9 @@
}
catch (Exception e)
{
- _logger.info("Unable to create InVM Qpid.AMQP on port " + port);
+ _logger.info("Unable to create InVM Qpid.AMQP on port " + port + ". Because: " + e.getCause());
_logger.error(e);
- throw new AMQVMBrokerCreationException(port, "Unable to create InVM Qpid.AMQP on port " + port);
+ throw new AMQVMBrokerCreationException(port, e.getCause() + " Stopped InVM Qpid.AMQP creation");
}
_acceptor.bind(pipe, provider);
@@ -211,7 +221,7 @@
catch (IOException e)
{
_logger.error(e);
- throw new AMQVMBrokerCreationException(port, "Unable to create InVM Qpid.AMQP on port " + port);
+ throw new AMQVMBrokerCreationException(port, e.getCause() + " Stopped binding of InVM Qpid.AMQP");
}
}
else