public abstract class AbstractProxyLogicHandler extends Object implements ProxyLogicHandler
Based upon SSLHandler from mina-filter-ssl.
Constructor and Description |
---|
AbstractProxyLogicHandler(ProxyIoSession proxyIoSession)
Creates a new
AbstractProxyLogicHandler . |
Modifier and Type | Method and Description |
---|---|
protected void |
closeSession(String message)
Closes the session.
|
protected void |
closeSession(String message,
Throwable t)
Closes the session.
|
void |
enqueueWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest)
Enqueue a message to be written once handshaking is complete.
|
protected void |
flushPendingWriteRequests()
Send any write requests which were queued whilst waiting for handshaking to complete.
|
protected ProxyFilter |
getProxyFilter() |
ProxyIoSession |
getProxyIoSession() |
protected IoSession |
getSession() |
boolean |
isHandshakeComplete()
Tests if handshake process is complete.
|
protected void |
setHandshakeComplete()
Signals that the handshake has finished.
|
protected WriteFuture |
writeData(IoFilter.NextFilter nextFilter,
IoBuffer data)
Writes data to the proxy server.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
doHandshake, messageReceived
public AbstractProxyLogicHandler(ProxyIoSession proxyIoSession)
AbstractProxyLogicHandler
.proxyIoSession
- ProxyIoSession
in use.protected ProxyFilter getProxyFilter()
ProxyFilter
.protected IoSession getSession()
public ProxyIoSession getProxyIoSession()
getProxyIoSession
in interface ProxyLogicHandler
ProxyIoSession
object.protected WriteFuture writeData(IoFilter.NextFilter nextFilter, IoBuffer data)
nextFilter
- the next filterdata
- Data buffer to be written.public boolean isHandshakeComplete()
ProxyLogicHandler
isHandshakeComplete
in interface ProxyLogicHandler
protected final void setHandshakeComplete()
protected void flushPendingWriteRequests() throws Exception
Exception
- If we can't flush the pending write requestspublic void enqueueWriteRequest(IoFilter.NextFilter nextFilter, WriteRequest writeRequest)
enqueueWriteRequest
in interface ProxyLogicHandler
nextFilter
- the next filter in filter chainwriteRequest
- the data to be writtenprotected void closeSession(String message, Throwable t)
message
- the error messaget
- the exception which caused the session closingprotected void closeSession(String message)
message
- the error messageCopyright © 2004–2021 Apache MINA Project. All rights reserved.