ProxyLogicHandler
AbstractHttpLogicHandler
, AbstractSocksLogicHandler
public abstract class AbstractProxyLogicHandler extends Object implements ProxyLogicHandler
Based upon SSLHandler from mina-filter-ssl.
Constructor | Description |
---|---|
AbstractProxyLogicHandler(ProxyIoSession proxyIoSession) |
Creates a new
AbstractProxyLogicHandler . |
Modifier and Type | Method | 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–2018 Apache MINA Project. All rights reserved.