Package org.apache.mina.proxy.event
Class IoSessionEventQueue
- java.lang.Object
-
- org.apache.mina.proxy.event.IoSessionEventQueue
-
public class IoSessionEventQueue extends Object
IoSessionEventQueue.java - Queue that contains filtered session events while handshake isn't done.- Since:
- MINA 2.0.0-M3
- Author:
- Apache MINA Project
-
-
Constructor Summary
Constructors Constructor Description IoSessionEventQueue(ProxyIoSession proxyIoSession)
Creates a new proxyIoSession instance
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
enqueueEventIfNecessary(IoSessionEvent evt)
Event is enqueued only if necessary : - socks proxies do not need the reconnection feature so events are always forwarded for thesevoid
flushPendingSessionEvents()
Send any session event which were queued while waiting for handshaking to complete.
-
-
-
Constructor Detail
-
IoSessionEventQueue
public IoSessionEventQueue(ProxyIoSession proxyIoSession)
Creates a new proxyIoSession instance- Parameters:
proxyIoSession
- The proxy session instance
-
-
Method Detail
-
enqueueEventIfNecessary
public void enqueueEventIfNecessary(IoSessionEvent evt)
Event is enqueued only if necessary : - socks proxies do not need the reconnection feature so events are always forwarded for these. - http proxies events will be enqueued while handshake has not been completed or until connection was closed. If connection was prematurely closed previous events are discarded and only the session closed is delivered.- Parameters:
evt
- the event to enqueue
-
flushPendingSessionEvents
public void flushPendingSessionEvents() throws Exception
Send any session event which were queued while waiting for handshaking to complete. Please note this is an internal method. DO NOT USE it in your code.- Throws:
Exception
- If something went wrong while flushing the pending events
-
-