public abstract class AbstractProcessor<S> extends Object implements Processor<S>, WebConnection
Modifier and Type | Field and Description |
---|---|
protected static StringManager |
sm |
Modifier | Constructor and Description |
---|---|
protected |
AbstractProcessor(UpgradeToken upgradeToken,
AbstractServletInputStream upgradeServletInputStream,
AbstractServletOutputStream<S> upgradeServletOutputStream) |
protected static final StringManager sm
protected AbstractProcessor(UpgradeToken upgradeToken, AbstractServletInputStream upgradeServletInputStream, AbstractServletOutputStream<S> upgradeServletOutputStream)
protected abstract Log getLog()
public void close() throws Exception
close
in interface AutoCloseable
Exception
public ServletInputStream getInputStream() throws IOException
javax.servlet.http.WebConnection
ServletInputStream
for reading data from
the client.getInputStream
in interface WebConnection
IOException
- If an I/O occurs while obtaining the streampublic ServletOutputStream getOutputStream() throws IOException
javax.servlet.http.WebConnection
ServletOutputStream
for writing data to
the client.getOutputStream
in interface WebConnection
IOException
- If an I/O occurs while obtaining the streampublic UpgradeToken getUpgradeToken()
getUpgradeToken
in interface Processor<S>
public final AbstractEndpoint.Handler.SocketState upgradeDispatch(SocketStatus status) throws IOException
upgradeDispatch
in interface Processor<S>
IOException
public final void recycle(boolean socketClosing)
public final Executor getExecutor()
getExecutor
in interface Processor<S>
public final AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socketWrapper) throws IOException
process
in interface Processor<S>
IOException
public final AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws IOException
event
in interface Processor<S>
IOException
public final AbstractEndpoint.Handler.SocketState asyncDispatch(SocketStatus status)
asyncDispatch
in interface Processor<S>
public void errorDispatch()
errorDispatch
in interface Processor<S>
public final AbstractEndpoint.Handler.SocketState asyncPostProcess()
asyncPostProcess
in interface Processor<S>
public final Request getRequest()
getRequest
in interface Processor<S>
public final void setSslSupport(SSLSupport sslSupport)
setSslSupport
in interface Processor<S>
public ByteBuffer getLeftoverInput()
Processor
getLeftoverInput
in interface Processor<S>
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.