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.AutoCloseable
java.lang.Exception
public ServletInputStream getInputStream() throws java.io.IOException
javax.servlet.http.WebConnection
ServletInputStream
for reading data from
the client.getInputStream
in interface WebConnection
java.io.IOException
- If an I/O occurs while obtaining the streampublic ServletOutputStream getOutputStream() throws java.io.IOException
javax.servlet.http.WebConnection
ServletOutputStream
for writing data to
the client.getOutputStream
in interface WebConnection
java.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.IOException
public 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()
Processor
getLeftoverInput
in interface Processor<S>
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.