svn commit: r547627 - /incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/transport/VmPipeTransportConnection.java

[ritchiem]

Author: ritchiem
Date: Fri Jun 15 04:21:40 2007
New Revision: 547627

URL: http://svn.apache.org/viewvc?view=rev&rev=547627
Log:
QPID-511 adjusted to use the ReadWriteThreadModel rather than setting editing 
the filterChain directly which could cause problems when using an InVM 
transport due to the way the InVM transport alters the filter chain during a 
connect call.

Modified:
    
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/transport/VmPipeTransportConnection.java

Modified: 
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/transport/VmPipeTransportConnection.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/transport/VmPipeTransportConnection.java?view=diff&rev=547627&r1=547626&r2=547627
==============================================================================
--- 
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/transport/VmPipeTransportConnection.java
 (original)
+++ 
incubator/qpid/branches/M2/java/client/src/main/java/org/apache/qpid/client/transport/VmPipeTransportConnection.java
 Fri Jun 15 04:21:40 2007
@@ -29,6 +29,7 @@
 import org.apache.qpid.jms.BrokerDetails;
 import org.apache.qpid.pool.PoolingFilter;
 import org.apache.qpid.pool.ReferenceCountingExecutorService;
+import org.apache.qpid.pool.ReadWriteThreadModel;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -50,11 +51,8 @@
     {
         final VmPipeConnector ioConnector = new VmPipeConnector();
         final IoServiceConfig cfg = ioConnector.getDefaultConfig();
-        ReferenceCountingExecutorService executorService = 
ReferenceCountingExecutorService.getInstance();
-        PoolingFilter asyncRead = 
PoolingFilter.createAynschReadPoolingFilter(executorService, 
"AsynchronousReadFilter");
-        cfg.getFilterChain().addFirst("AsynchronousReadFilter", asyncRead);
-        PoolingFilter asyncWrite = 
PoolingFilter.createAynschWritePoolingFilter(executorService, 
"AsynchronousWriteFilter");
-        cfg.getFilterChain().addLast("AsynchronousWriteFilter", asyncWrite);
+
+        cfg.setThreadModel(ReadWriteThreadModel.getInstance());             
 
         final VmPipeAddress address = new VmPipeAddress(_port);
         _logger.info("Attempting connection to " + address);