com.liferay.portal.resiliency.spi.agent

Class HttpClientSPIAgent

Object

com.liferay.portal.resiliency.spi.agent.HttpClientSPIAgent

All Implemented Interfaces:

com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

public class HttpClientSPIAgent
extends Object
implements com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

Author:

Shuyang Zhou

Nested Class Summary

Nested classes/interfaces inherited from interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent.Lifecycle

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
HttpClientSPIAgent(com.liferay.portal.kernel.resiliency.spi.SPIConfiguration spiConfiguration, com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference)

Method Summary

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 request)
javax.servlet.http.HttpServletResponse	prepareResponse(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
protected void	returnSocket(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, Exception exception)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAPPING_PATTERN

protected static final String MAPPING_PATTERN

See Also:

Constant Field Values

SPI_AGENT_CONTEXT_PATH

protected static final String SPI_AGENT_CONTEXT_PATH

See Also:

Constant Field Values

httpServletRequestContent

protected final byte[] httpServletRequestContent

registrationReference

protected final com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference

socketAddress

protected final SocketAddress socketAddress

socketBlockingQueue

protected final BlockingQueue<Socket> socketBlockingQueue

Constructor Detail

HttpClientSPIAgent

public HttpClientSPIAgent(com.liferay.portal.kernel.resiliency.spi.SPIConfiguration spiConfiguration,
                          com.liferay.portal.kernel.nio.intraband.RegistrationReference registrationReference)
                   throws UnknownHostException

Throws:

UnknownHostException

Method Detail

destroy

public void destroy()

Specified by:

destroy in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

init

public void init(com.liferay.portal.kernel.resiliency.spi.SPI spi)
          throws com.liferay.portal.kernel.resiliency.PortalResiliencyException

Specified by:

init in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

Throws:

com.liferay.portal.kernel.resiliency.PortalResiliencyException

prepareRequest

public javax.servlet.http.HttpServletRequest prepareRequest(javax.servlet.http.HttpServletRequest request)
                                                     throws IOException

Specified by:

prepareRequest in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

Throws:

IOException

prepareResponse

public javax.servlet.http.HttpServletResponse prepareResponse(javax.servlet.http.HttpServletRequest request,
                                                              javax.servlet.http.HttpServletResponse response)

Specified by:

prepareResponse in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

service

public void service(javax.servlet.http.HttpServletRequest request,
                    javax.servlet.http.HttpServletResponse response)
             throws com.liferay.portal.kernel.resiliency.PortalResiliencyException

Specified by:

service in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

Throws:

com.liferay.portal.kernel.resiliency.PortalResiliencyException

transferResponse

public void transferResponse(javax.servlet.http.HttpServletRequest request,
                             javax.servlet.http.HttpServletResponse response,
                             Exception exception)
                      throws IOException

Specified by:

transferResponse in interface com.liferay.portal.kernel.resiliency.spi.agent.SPIAgent

Throws:

IOException

borrowSocket

protected Socket borrowSocket()
                       throws IOException

Throws:

IOException

consumeHttpResponseHead

protected boolean consumeHttpResponseHead(DataInput dataInput)
                                   throws IOException

Throws:

IOException

returnSocket

protected void returnSocket(Socket socket,
                            boolean forceCloseSocket)