public class IoSessionEventQueue
extends java.lang.Object
构造器和说明 |
---|
IoSessionEventQueue(ProxyIoSession proxyIoSession) |
限定符和类型 | 方法和说明 |
---|---|
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
|
void |
flushPendingSessionEvents()
Send any session event which were queued while waiting for handshaking to complete.
|
public IoSessionEventQueue(ProxyIoSession proxyIoSession)
public void enqueueEventIfNecessary(IoSessionEvent evt)
evt
- the event to enqueuepublic void flushPendingSessionEvents() throws java.lang.Exception
java.lang.Exception
- If something went wrong while flushing the pending events