public class HttpClientSPIAgent
extends java.lang.Object
implements com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent
| Modifier and Type | Field and Description |
|---|---|
protected byte[] |
httpServletRequestContent |
protected static java.lang.String |
MAPPING_PATTERN |
protected com.liferay.portal.kernel.nio.intraband.RegistrationReference |
registrationReference |
protected java.net.SocketAddress |
socketAddress |
protected java.util.concurrent.BlockingQueue<java.net.Socket> |
socketBlockingQueue |
protected static java.lang.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 java.net.Socket |
borrowSocket() |
protected boolean |
consumeHttpResponseHead(java.io.DataInput dataInput) |
void |
destroy() |
void |
init(com.liferay.portal.kernel.resiliency.spi.SPI spi) |
javax.servlet.http.HttpServletRequest |
prepareRequest(javax.servlet.http.HttpServletRequest request) |
javax.servlet.http.HttpServletResponse |
prepareResponse(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response) |
protected void |
returnSocket(java.net.Socket socket,
boolean forceCloseSocket) |
void |
service(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response) |
void |
transferResponse(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
java.lang.Exception exception) |
protected static final java.lang.String MAPPING_PATTERN
protected static final java.lang.String SPI_AGENT_CONTEXT_PATH
protected final byte[] httpServletRequestContent
protected final com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference
protected final java.net.SocketAddress socketAddress
protected final java.util.concurrent.BlockingQueue<java.net.Socket> socketBlockingQueue
public HttpClientSPIAgent(com.liferay.portal.kernel.resiliency.spi.SPIConfiguration spiConfiguration,
com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference)
throws java.net.UnknownHostException
java.net.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 request)
throws java.io.IOException
prepareRequest in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentjava.io.IOExceptionpublic javax.servlet.http.HttpServletResponse prepareResponse(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
prepareResponse in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentpublic void service(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
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 request,
javax.servlet.http.HttpServletResponse response,
java.lang.Exception exception)
throws java.io.IOException
transferResponse in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgentjava.io.IOExceptionprotected java.net.Socket borrowSocket()
throws java.io.IOException
java.io.IOExceptionprotected boolean consumeHttpResponseHead(java.io.DataInput dataInput)
throws java.io.IOException
java.io.IOExceptionprotected void returnSocket(java.net.Socket socket,
boolean forceCloseSocket)