public abstract class AbstractProcessor<S> extends java.lang.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 java.lang.Exception
close in interface java.lang.AutoCloseablejava.lang.Exceptionpublic ServletInputStream getInputStream() throws java.io.IOException
javax.servlet.http.WebConnectionServletInputStream for reading data from
the client.getInputStream in interface WebConnectionjava.io.IOException - If an I/O occurs while obtaining the streampublic ServletOutputStream getOutputStream() throws java.io.IOException
javax.servlet.http.WebConnectionServletOutputStream for writing data to
the client.getOutputStream in interface WebConnectionjava.io.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 java.io.IOException
upgradeDispatch in interface Processor<S>java.io.IOExceptionpublic final void recycle(boolean socketClosing)
public final java.util.concurrent.Executor getExecutor()
getExecutor in interface Processor<S>public final AbstractEndpoint.Handler.SocketState process(SocketWrapper<S> socketWrapper) throws java.io.IOException
public final AbstractEndpoint.Handler.SocketState event(SocketStatus status) throws java.io.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 java.nio.ByteBuffer getLeftoverInput()
ProcessorgetLeftoverInput in interface Processor<S>Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.