public class HttpClientSPIAgent
extends Object
implements com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent
| Modifier and Type | Field and Description |
|---|---|
protected byte[] |
httpServletRequestContent |
protected static String |
MAPPING_PATTERN |
protected com.liferay.portal.kernel.nio.intraband.RegistrationReference |
registrationReference |
protected SocketAddress |
socketAddress |
protected BlockingQueue<Socket> |
socketBlockingQueue |
protected static String |
SPI_AGENT_CONTEXT_PATH |
| Constructor and Description |
|---|
HttpClientSPIAgent(com.liferay.portal.kernel.resiliency.spi.SPIConfiguration spiConfiguration,
com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference) |
| Modifier and Type | Method and Description |
|---|---|
protected Socket |
borrowSocket() |
protected boolean |
consumeHttpResponseHead(DataInput dataInput) |
void |
destroy() |
void |
init(com.liferay.portal.kernel.resiliency.spi.SPI spi) |
javax.servlet.http.HttpServletRequest |
prepareRequest(javax.servlet.http.HttpServletRequest httpServletRequest) |
javax.servlet.http.HttpServletResponse |
prepareResponse(javax.servlet.http.HttpServletRequest httpServletRequest,
javax.servlet.http.HttpServletResponse httpServletResponse) |
protected void |
returnSocket(Socket socket,
boolean forceCloseSocket) |
void |
service(javax.servlet.http.HttpServletRequest httpServletRequest,
javax.servlet.http.HttpServletResponse httpServletResponse) |
void |
transferResponse(javax.servlet.http.HttpServletRequest httpServletRequest,
javax.servlet.http.HttpServletResponse httpServletResponse,
Exception exception) |
protected static final String MAPPING_PATTERN
protected static final String SPI_AGENT_CONTEXT_PATH
protected final byte[] httpServletRequestContent
protected final com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference
protected final SocketAddress socketAddress
protected final BlockingQueue<Socket> socketBlockingQueue
public HttpClientSPIAgent(com.liferay.portal.kernel.resiliency.spi.SPIConfiguration spiConfiguration,
com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference)
throws UnknownHostException
UnknownHostExceptionpublic void destroy()
destroy in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentpublic void init(com.liferay.portal.kernel.resiliency.spi.SPI spi)
throws com.liferay.portal.kernel.resiliency.PortalResiliencyException
init in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentcom.liferay.portal.kernel.resiliency.PortalResiliencyExceptionpublic javax.servlet.http.HttpServletRequest prepareRequest(javax.servlet.http.HttpServletRequest httpServletRequest)
throws IOException
prepareRequest in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentIOExceptionpublic javax.servlet.http.HttpServletResponse prepareResponse(javax.servlet.http.HttpServletRequest httpServletRequest,
javax.servlet.http.HttpServletResponse httpServletResponse)
prepareResponse in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentpublic void service(javax.servlet.http.HttpServletRequest httpServletRequest,
javax.servlet.http.HttpServletResponse httpServletResponse)
throws com.liferay.portal.kernel.resiliency.PortalResiliencyException
service in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentcom.liferay.portal.kernel.resiliency.PortalResiliencyExceptionpublic void transferResponse(javax.servlet.http.HttpServletRequest httpServletRequest,
javax.servlet.http.HttpServletResponse httpServletResponse,
Exception exception)
throws IOException
transferResponse in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentIOExceptionprotected Socket borrowSocket()
throws IOException
IOExceptionprotected boolean consumeHttpResponseHead(DataInput dataInput)
throws IOException
IOExceptionprotected void returnSocket(Socket socket,
boolean forceCloseSocket)