org.apache.mina.transport.vmpipe

Class VmPipeFilterChain

java.lang.Object

org.apache.mina.core.filterchain.DefaultIoFilterChain

org.apache.mina.transport.vmpipe.VmPipeFilterChain

All Implemented Interfaces:

IoFilterChain

class VmPipeFilterChain
extends DefaultIoFilterChain

TODO Add documentation

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	VmPipeFilterChain.VmPipeIoProcessor

Nested classes/interfaces inherited from interface org.apache.mina.core.filterchain.IoFilterChain

IoFilterChain.Entry

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Queue<IoEvent>	eventQueue
private boolean	flushEnabled
private IoProcessor<VmPipeSession>	processor
private boolean	sessionOpened

Fields inherited from class org.apache.mina.core.filterchain.DefaultIoFilterChain

SESSION_CREATED_FUTURE

Constructor Summary

Constructors

Constructor and Description
VmPipeFilterChain(AbstractIoSession session)

Method Summary

Modifier and Type	Method and Description
private void	fireEvent(IoEvent e)
void	fireExceptionCaught(java.lang.Throwable cause) Fires a IoHandler.exceptionCaught(IoSession, Throwable) event.
void	fireFilterClose() Fires a IoSession.close() event.
void	fireFilterWrite(WriteRequest writeRequest) Fires a IoSession.write(Object) event.
void	fireMessageReceived(java.lang.Object message) Fires a IoHandler.messageReceived(IoSession, Object) event.
void	fireMessageSent(WriteRequest request) Fires a IoHandler.messageSent(IoSession, Object) event.
void	fireSessionClosed() Fires a IoHandler.sessionClosed(IoSession) event.
void	fireSessionCreated() Fires a IoHandler.sessionCreated(IoSession) event.
void	fireSessionIdle(IdleStatus status) Fires a IoHandler.sessionIdle(IoSession, IdleStatus) event.
void	fireSessionOpened() Fires a IoHandler.sessionOpened(IoSession) event.
private void	flushEvents()
private static void	flushPendingDataQueues(VmPipeSession s)
(package private) IoProcessor<VmPipeSession>	getProcessor()
private void	pushEvent(IoEvent e)
private void	pushEvent(IoEvent e, boolean flushNow)
void	start()

Methods inherited from class org.apache.mina.core.filterchain.DefaultIoFilterChain

addAfter, addBefore, addFirst, addLast, clear, contains, contains, contains, fireInputClosed, get, get, getAll, getAllReversed, getEntry, getEntry, getEntry, getNextFilter, getNextFilter, getNextFilter, getSession, remove, remove, remove, replace, replace, replace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

eventQueue

private final java.util.Queue<IoEvent> eventQueue

processor

private final IoProcessor<VmPipeSession> processor

flushEnabled

private volatile boolean flushEnabled

sessionOpened

private volatile boolean sessionOpened

Constructor Detail

VmPipeFilterChain

VmPipeFilterChain(AbstractIoSession session)

Method Detail

getProcessor

IoProcessor<VmPipeSession> getProcessor()

start

public void start()

pushEvent

private void pushEvent(IoEvent e)

pushEvent

private void pushEvent(IoEvent e,
                       boolean flushNow)

flushEvents

private void flushEvents()

fireEvent

private void fireEvent(IoEvent e)

flushPendingDataQueues

private static void flushPendingDataQueues(VmPipeSession s)

fireFilterClose

public void fireFilterClose()

Description copied from interface: IoFilterChain

Fires a IoSession.close() event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireFilterClose in interface IoFilterChain

Overrides:

fireFilterClose in class DefaultIoFilterChain

fireFilterWrite

public void fireFilterWrite(WriteRequest writeRequest)

Description copied from interface: IoFilterChain

Fires a IoSession.write(Object) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireFilterWrite in interface IoFilterChain

Overrides:

fireFilterWrite in class DefaultIoFilterChain

Parameters:

writeRequest - The message to write

fireExceptionCaught

public void fireExceptionCaught(java.lang.Throwable cause)

Description copied from interface: IoFilterChain

Fires a IoHandler.exceptionCaught(IoSession, Throwable) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireExceptionCaught in interface IoFilterChain

Overrides:

fireExceptionCaught in class DefaultIoFilterChain

Parameters:

cause - The exception cause

fireMessageSent

public void fireMessageSent(WriteRequest request)

Description copied from interface: IoFilterChain

Fires a IoHandler.messageSent(IoSession, Object) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireMessageSent in interface IoFilterChain

Overrides:

fireMessageSent in class DefaultIoFilterChain

Parameters:

request - The sent request

fireSessionClosed

public void fireSessionClosed()

Description copied from interface: IoFilterChain

Fires a IoHandler.sessionClosed(IoSession) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionClosed in interface IoFilterChain

Overrides:

fireSessionClosed in class DefaultIoFilterChain

fireSessionCreated

public void fireSessionCreated()

Description copied from interface: IoFilterChain

Fires a IoHandler.sessionCreated(IoSession) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionCreated in interface IoFilterChain

Overrides:

fireSessionCreated in class DefaultIoFilterChain

fireSessionIdle

public void fireSessionIdle(IdleStatus status)

Description copied from interface: IoFilterChain

Fires a IoHandler.sessionIdle(IoSession, IdleStatus) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionIdle in interface IoFilterChain

Overrides:

fireSessionIdle in class DefaultIoFilterChain

Parameters:

status - The current status to propagate

fireSessionOpened

public void fireSessionOpened()

Description copied from interface: IoFilterChain

Fires a IoHandler.sessionOpened(IoSession) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionOpened in interface IoFilterChain

Overrides:

fireSessionOpened in class DefaultIoFilterChain

fireMessageReceived

public void fireMessageReceived(java.lang.Object message)

Description copied from interface: IoFilterChain

Fires a IoHandler.messageReceived(IoSession, Object) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireMessageReceived in interface IoFilterChain

Overrides:

fireMessageReceived in class DefaultIoFilterChain

Parameters:

message - The received message