You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by tr...@apache.org on 2005/10/19 10:56:38 UTC
svn commit: r326489 [2/2] - in
/directory/network/trunk/src/java/org/apache/mina/transport: socket/nio/
socket/nio/support/ vmpipe/ vmpipe/support/
Copied: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java (from r326451, directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSession.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSession.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSession.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSession.java Wed Oct 19 01:56:19 2005
@@ -16,7 +16,7 @@
* limitations under the License.
*
*/
-package org.apache.mina.transport.socket.nio;
+package org.apache.mina.transport.socket.nio.support;
import java.net.SocketAddress;
import java.nio.channels.SelectionKey;
@@ -33,6 +33,7 @@
import org.apache.mina.common.support.BaseIoSession;
import org.apache.mina.common.support.IoSessionFilterChain;
import org.apache.mina.common.support.IoSessionManagerFilterChain;
+import org.apache.mina.transport.socket.nio.SocketSessionConfig;
import org.apache.mina.util.Queue;
/**
@@ -41,7 +42,7 @@
* @author Trustin Lee (trustin@apache.org)
* @version $Rev$, $Date$
*/
-class SocketSession extends BaseIoSession implements IoSession
+public class SocketSession extends BaseIoSession implements IoSession
{
private final IoSessionManagerFilterChain managerFilterChain;
@@ -66,13 +67,13 @@
/**
* Creates a new instance.
*/
- SocketSession( IoSessionManagerFilterChain managerFilterChain,
+ public SocketSession( IoSessionManagerFilterChain managerFilterChain,
SocketChannel ch, IoHandler defaultHandler )
{
this.managerFilterChain = managerFilterChain;
this.filterChain = new IoSessionFilterChain( this, managerFilterChain );
this.ch = ch;
- this.config = new SocketSessionConfig( this );
+ this.config = new SocketSessionConfigImpl( this );
this.writeRequestQueue = new Queue();
this.handler = defaultHandler;
this.remoteAddress = ch.socket().getRemoteSocketAddress();
@@ -109,7 +110,7 @@
return handler;
}
- public void notifyClose()
+ void notifyClose()
{
closeFuture.setClosed( true );
}
Added: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java?rev=326489&view=auto
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java (added)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionConfigImpl.java Wed Oct 19 01:56:19 2005
@@ -0,0 +1,146 @@
+/*
+ * @(#) $Id: SocketSessionConfig.java 326451 2005-10-19 08:07:09Z trustin $
+ *
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package org.apache.mina.transport.socket.nio.support;
+
+import java.net.SocketException;
+
+import org.apache.mina.common.IoSession;
+import org.apache.mina.common.IoSessionConfig;
+import org.apache.mina.common.support.BaseIoSessionConfig;
+import org.apache.mina.transport.socket.nio.SocketAcceptor;
+import org.apache.mina.transport.socket.nio.SocketConnector;
+import org.apache.mina.transport.socket.nio.SocketSessionConfig;
+
+/**
+ * A {@link IoSessionConfig} for socket transport (TCP/IP).
+ * You can downcast {@link IoSessionConfig} instance returned by
+ * {@link IoSession#getConfig()} if you've created datagram session
+ * using {@link SocketAcceptor} or {@link SocketConnector}.
+ *
+ * @author Trustin Lee (trustin@apache.org)
+ * @version $Rev: 326451 $, $Date: 2005-10-19 17:07:09 +0900 (ì, 19 10 2005) $,
+ */
+class SocketSessionConfigImpl extends BaseIoSessionConfig implements SocketSessionConfig
+{
+ private static final int DEFAULT_READ_BUFFER_SIZE = 1024;
+
+ private final SocketSession session;
+
+ private int readBufferSize = DEFAULT_READ_BUFFER_SIZE;
+
+ SocketSessionConfigImpl( SocketSession session )
+ {
+ this.session = session;
+ }
+
+ public boolean getKeepAlive() throws SocketException
+ {
+ return session.getChannel().socket().getKeepAlive();
+ }
+
+ public void setKeepAlive( boolean on ) throws SocketException
+ {
+ session.getChannel().socket().setKeepAlive( on );
+ }
+
+ public boolean getOOBInline() throws SocketException
+ {
+ return session.getChannel().socket().getOOBInline();
+ }
+
+ public void setOOBInline( boolean on ) throws SocketException
+ {
+ session.getChannel().socket().setOOBInline( on );
+ }
+
+ public boolean getReuseAddress() throws SocketException
+ {
+ return session.getChannel().socket().getReuseAddress();
+ }
+
+ public void setReuseAddress( boolean on ) throws SocketException
+ {
+ session.getChannel().socket().setReuseAddress( on );
+ }
+
+ public int getSoLinger() throws SocketException
+ {
+ return session.getChannel().socket().getSoLinger();
+ }
+
+ public void setSoLinger( boolean on, int linger ) throws SocketException
+ {
+ session.getChannel().socket().setSoLinger( on, linger );
+ }
+
+ public boolean getTcpNoDelay() throws SocketException
+ {
+ return session.getChannel().socket().getTcpNoDelay();
+ }
+
+ public void setTcpNoDelay( boolean on ) throws SocketException
+ {
+ session.getChannel().socket().setTcpNoDelay( on );
+ }
+
+ public int getTrafficClass() throws SocketException
+ {
+ return session.getChannel().socket().getTrafficClass();
+ }
+
+ public void setTrafficClass( int tc ) throws SocketException
+ {
+ session.getChannel().socket().setTrafficClass( tc );
+ }
+
+ public int getSendBufferSize() throws SocketException
+ {
+ return session.getChannel().socket().getSendBufferSize();
+ }
+
+ public void setSendBufferSize( int size ) throws SocketException
+ {
+ session.getChannel().socket().setSendBufferSize( size );
+ }
+
+ public int getReceiveBufferSize() throws SocketException
+ {
+ return session.getChannel().socket().getReceiveBufferSize();
+ }
+
+ public void setReceiveBufferSize( int size ) throws SocketException
+ {
+ session.getChannel().socket().setReceiveBufferSize( size );
+ }
+
+ public int getSessionReceiveBufferSize()
+ {
+ return readBufferSize;
+ }
+
+ public void setSessionReceiveBufferSize( int size )
+ {
+ if( size <= 0 )
+ {
+ throw new IllegalArgumentException( "Invalid session receive buffer size: " + size );
+ }
+
+ this.readBufferSize = size;
+ }
+}
\ No newline at end of file
Copied: directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java (from r326451, directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/SocketSessionManagerFilterChain.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/socket/nio/support/SocketSessionManagerFilterChain.java Wed Oct 19 01:56:19 2005
@@ -1,4 +1,4 @@
-package org.apache.mina.transport.socket.nio;
+package org.apache.mina.transport.socket.nio.support;
import org.apache.mina.common.ByteBuffer;
import org.apache.mina.common.IoFilterChain;
@@ -13,9 +13,9 @@
*
* @author The Apache Directory Project
*/
-class SocketSessionManagerFilterChain extends IoSessionManagerFilterChain {
+public class SocketSessionManagerFilterChain extends IoSessionManagerFilterChain {
- SocketSessionManagerFilterChain( IoSessionManager manager )
+ public SocketSessionManagerFilterChain( IoSessionManager manager )
{
super( manager );
}
Modified: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java?rev=326489&r1=326488&r2=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java Wed Oct 19 01:56:19 2005
@@ -13,6 +13,9 @@
import org.apache.mina.common.IoSessionManagerConfig;
import org.apache.mina.common.support.BaseIoAcceptor;
import org.apache.mina.common.support.BaseIoAcceptorConfig;
+import org.apache.mina.transport.vmpipe.support.VmPipe;
+import org.apache.mina.transport.vmpipe.support.VmPipeFilter;
+import org.apache.mina.transport.vmpipe.support.VmPipeSessionManagerFilterChain;
/**
* Binds the specified {@link IoHandler} to the specified
@@ -61,7 +64,7 @@
}
boundHandlers.put( address,
- new Entry( this,
+ new VmPipe( this,
( VmPipeAddress ) address,
filterChain,
handler ) );
@@ -97,27 +100,5 @@
public IoFilterChain getFilterChain()
{
return filterChain;
- }
-
- static class Entry
- {
- final VmPipeAcceptor acceptor;
-
- final VmPipeAddress address;
-
- final VmPipeSessionManagerFilterChain managerFilterChain;
-
- final IoHandler handler;
-
- private Entry( VmPipeAcceptor acceptor,
- VmPipeAddress address,
- VmPipeSessionManagerFilterChain managerFilterChain,
- IoHandler handler )
- {
- this.acceptor = acceptor;
- this.address = address;
- this.managerFilterChain = managerFilterChain;
- this.handler = handler;
- }
}
}
Modified: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java?rev=326489&r1=326488&r2=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeConnector.java Wed Oct 19 01:56:19 2005
@@ -13,7 +13,11 @@
import org.apache.mina.common.IoSessionManagerConfig;
import org.apache.mina.common.support.BaseIoConnectorConfig;
import org.apache.mina.common.support.BaseIoSessionManager;
-import org.apache.mina.transport.vmpipe.VmPipeAcceptor.Entry;
+import org.apache.mina.transport.vmpipe.support.VmPipe;
+import org.apache.mina.transport.vmpipe.support.VmPipeFilter;
+import org.apache.mina.transport.vmpipe.support.VmPipeIdleStatusChecker;
+import org.apache.mina.transport.vmpipe.support.VmPipeSession;
+import org.apache.mina.transport.vmpipe.support.VmPipeSessionManagerFilterChain;
import org.apache.mina.util.AnonymousSocketAddress;
/**
@@ -72,7 +76,7 @@
throw new IllegalArgumentException(
"address must be VmPipeAddress." );
- Entry entry = ( Entry ) VmPipeAcceptor.boundHandlers.get( address );
+ VmPipe entry = ( VmPipe ) VmPipeAcceptor.boundHandlers.get( address );
if( entry == null )
throw new IOException( "Endpoint unavailable: " + address );
@@ -82,7 +86,7 @@
handler,
entry );
- VmPipeIdleStatusChecker.INSTANCE.addSession( session );
+ VmPipeIdleStatusChecker.getInstance().addSession( session );
ConnectFuture future = new ConnectFuture();
future.setSession( session );
return future;
Added: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java?rev=326489&view=auto
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java (added)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipe.java Wed Oct 19 01:56:19 2005
@@ -0,0 +1,47 @@
+/*
+ * @(#) $Id$
+ */
+package org.apache.mina.transport.vmpipe.support;
+
+import org.apache.mina.common.IoHandler;
+import org.apache.mina.transport.vmpipe.VmPipeAcceptor;
+import org.apache.mina.transport.vmpipe.VmPipeAddress;
+
+public class VmPipe
+{
+ private final VmPipeAcceptor acceptor;
+ private final VmPipeAddress address;
+ private final VmPipeSessionManagerFilterChain managerFilterChain;
+ private final IoHandler handler;
+
+ public VmPipe( VmPipeAcceptor acceptor,
+ VmPipeAddress address,
+ VmPipeSessionManagerFilterChain managerFilterChain,
+ IoHandler handler )
+ {
+ this.acceptor = acceptor;
+ this.address = address;
+ this.managerFilterChain = managerFilterChain;
+ this.handler = handler;
+ }
+
+ public VmPipeAcceptor getAcceptor()
+ {
+ return acceptor;
+ }
+
+ public VmPipeAddress getAddress()
+ {
+ return address;
+ }
+
+ public IoHandler getHandler()
+ {
+ return handler;
+ }
+
+ public VmPipeSessionManagerFilterChain getManagerFilterChain()
+ {
+ return managerFilterChain;
+ }
+}
\ No newline at end of file
Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java (from r326410, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeFilter.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeFilter.java&r1=326410&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeFilter.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeFilter.java Wed Oct 19 01:56:19 2005
@@ -1,7 +1,7 @@
/*
* @(#) $Id$
*/
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
import org.apache.mina.common.IdleStatus;
import org.apache.mina.common.IoFilterAdapter;
@@ -13,7 +13,7 @@
* @author Trustin Lee (trustin@apache.org)
* @version $Rev$, $Date$
*/
-class VmPipeFilter extends IoFilterAdapter
+public class VmPipeFilter extends IoFilterAdapter
{
public void messageReceived( NextFilter nextFilter,
IoSession session, Object message )
Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java (from r326410, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeIdleStatusChecker.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeIdleStatusChecker.java&r1=326410&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeIdleStatusChecker.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeIdleStatusChecker.java Wed Oct 19 01:56:19 2005
@@ -1,7 +1,7 @@
/*
* @(#) $Id$
*/
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
import java.util.IdentityHashMap;
import java.util.Iterator;
@@ -16,9 +16,14 @@
* @author Trustin Lee (trustin@apache.org)
* @version $Rev$, $Date$
*/
-class VmPipeIdleStatusChecker
+public class VmPipeIdleStatusChecker
{
- static final VmPipeIdleStatusChecker INSTANCE = new VmPipeIdleStatusChecker();
+ private static final VmPipeIdleStatusChecker INSTANCE = new VmPipeIdleStatusChecker();
+
+ public static VmPipeIdleStatusChecker getInstance()
+ {
+ return INSTANCE;
+ }
private final Map sessions = new IdentityHashMap(); // will use as a set
@@ -29,7 +34,7 @@
worker.start();
}
- void addSession( VmPipeSession session )
+ public void addSession( VmPipeSession session )
{
synchronized( sessions )
{
Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java (from r326451, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSession.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSession.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSession.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSession.java Wed Oct 19 01:56:19 2005
@@ -1,7 +1,7 @@
/*
* @(#) $Id$
*/
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
import java.io.IOException;
import java.net.SocketAddress;
@@ -18,7 +18,7 @@
import org.apache.mina.common.support.IoSessionFilterChain;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolEncoder;
-import org.apache.mina.transport.vmpipe.VmPipeAcceptor.Entry;
+import org.apache.mina.transport.vmpipe.VmPipeSessionConfig;
import org.apache.mina.util.ExceptionUtil;
/**
@@ -27,7 +27,7 @@
* @author Trustin Lee (trustin@apache.org)
* @version $Rev$, $Date$
*/
-class VmPipeSession extends BaseIoSession implements IoSession
+public class VmPipeSession extends BaseIoSession implements IoSession
{
private final SocketAddress localAddress;
@@ -50,14 +50,14 @@
/**
* Constructor for client-side session.
*/
- VmPipeSession( Object lock, SocketAddress localAddress,
+ public VmPipeSession( Object lock, SocketAddress localAddress,
VmPipeSessionManagerFilterChain managerFilterChain,
IoHandler handler,
- Entry remoteEntry ) throws IOException
+ VmPipe remoteEntry ) throws IOException
{
this.lock = lock;
this.localAddress = localAddress;
- this.remoteAddress = remoteEntry.address;
+ this.remoteAddress = remoteEntry.getAddress();
this.handler = handler;
this.filterChain = new IoSessionFilterChain( this, managerFilterChain );
this.managerFilterChain = managerFilterChain;
@@ -67,11 +67,11 @@
// initialize remote session
try
{
- remoteEntry.handler.sessionCreated( remoteSession );
+ remoteEntry.getHandler().sessionCreated( remoteSession );
}
catch( Throwable t )
{
- remoteEntry.acceptor.getExceptionMonitor().exceptionCaught( remoteEntry.acceptor, t );
+ remoteEntry.getAcceptor().getExceptionMonitor().exceptionCaught( remoteEntry.getAcceptor(), t );
IOException e = new IOException( "Failed to initialize remote session." );
e.initCause( t );
throw e;
@@ -87,21 +87,21 @@
ExceptionUtil.throwException( t );
}
- remoteEntry.managerFilterChain.sessionOpened( remoteSession );
+ remoteEntry.getManagerFilterChain().sessionOpened( remoteSession );
managerFilterChain.sessionOpened( this );
}
/**
* Constructor for server-side session.
*/
- VmPipeSession( VmPipeSession remoteSession, Entry entry )
+ private VmPipeSession( VmPipeSession remoteSession, VmPipe entry )
{
this.lock = remoteSession.lock;
this.localAddress = remoteSession.remoteAddress;
this.remoteAddress = remoteSession.localAddress;
- this.handler = entry.handler;
- this.managerFilterChain = entry.managerFilterChain;
- this.filterChain = new IoSessionFilterChain( this, entry.managerFilterChain );
+ this.handler = entry.getHandler();
+ this.managerFilterChain = entry.getManagerFilterChain();
+ this.filterChain = new IoSessionFilterChain( this, entry.getManagerFilterChain() );
this.remoteSession = remoteSession;
}
Copied: directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java (from r326451, directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSessionManagerFilterChain.java)
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java?p2=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java&p1=directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSessionManagerFilterChain.java&r1=326451&r2=326489&rev=326489&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/VmPipeSessionManagerFilterChain.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionManagerFilterChain.java Wed Oct 19 01:56:19 2005
@@ -1,13 +1,13 @@
-package org.apache.mina.transport.vmpipe;
+package org.apache.mina.transport.vmpipe.support;
import org.apache.mina.common.IoSession;
import org.apache.mina.common.IoSessionManager;
import org.apache.mina.common.IoFilter.WriteRequest;
import org.apache.mina.common.support.IoSessionManagerFilterChain;
-class VmPipeSessionManagerFilterChain extends IoSessionManagerFilterChain {
+public class VmPipeSessionManagerFilterChain extends IoSessionManagerFilterChain {
- VmPipeSessionManagerFilterChain( IoSessionManager manager )
+ public VmPipeSessionManagerFilterChain( IoSessionManager manager )
{
super( manager );
}