svn commit: r469430 - /incubator/qpid/trunk/qpid/java/client/src/org/apache/qpid/client/transport/TransportConnection.java

[ritchiem]

Author: ritchiem
Date: Tue Oct 31 01:49:19 2006
New Revision: 469430

URL: http://svn.apache.org/viewvc?view=rev&rev=469430
Log:
Added additional logging to diagnose issues when unable to create an in VM 
broker 

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=469430&r1=469429&r2=469430
==============================================================================
--- 
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 Oct 31 01:49:19 2006
@@ -21,9 +21,11 @@
 import org.apache.mina.common.IoConnector;
 import org.apache.mina.common.IoHandlerAdapter;
 import org.apache.mina.common.IoServiceConfig;
-import org.apache.mina.transport.socket.nio.SocketConnector;
+
+
 import org.apache.mina.transport.vmpipe.VmPipeAcceptor;
 import org.apache.mina.transport.vmpipe.VmPipeAddress;
+import org.apache.mina.transport.socket.nio.SocketConnector;
 import org.apache.qpid.client.AMQBrokerDetails;
 import org.apache.qpid.jms.BrokerDetails;
 import org.apache.qpid.pool.ReadWriteThreadModel;
@@ -111,7 +113,18 @@
                 {
                     public IoConnector newSocketConnector()
                     {
-                        SocketConnector result = new SocketConnector(); // 
non-blocking connector
+                        SocketConnector result;
+                        //fixme improve get 
+                        if (Boolean.getBoolean("qpidnio"))
+                        {
+                            _logger.warn("Using Qpid NIO");
+                            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
@@ -196,7 +209,7 @@
                 catch (Exception e)
                 {
                     _logger.info("Unable to create InVM Qpid.AMQP on port " + 
port);
-                    _logger.info(e);
+                    _logger.error(e);
                     throw new AMQVMBrokerCreationException(port, "Unable to 
create InVM Qpid.AMQP on port " + port);
                 }
 
@@ -207,6 +220,7 @@
             }
             catch (IOException e)
             {
+                _logger.error(e);
                 throw new AMQVMBrokerCreationException(port, "Unable to create 
InVM Qpid.AMQP on port " + port);
             }
         }