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
