com.liferay.portal.poller

Class PollerRequestHandlerImpl

Object

com.liferay.portal.poller.PollerRequestHandlerImpl

All Implemented Interfaces:

com.liferay.portal.kernel.messaging.MessageListener, PollerRequestHandler

public class PollerRequestHandlerImpl
extends Object
implements PollerRequestHandler, com.liferay.portal.kernel.messaging.MessageListener

Author:

Michael C. Han, Brian Wing Shun Chan, Edward Han

Constructor Summary

Constructors

Constructor and Description
PollerRequestHandlerImpl()

Method Summary

Modifier and Type	Method and Description
protected com.liferay.portal.kernel.poller.PollerRequest	createPollerRequest(com.liferay.portal.kernel.poller.PollerHeader pollerHeader, String portletId, boolean receiveRequest)
protected com.liferay.portal.kernel.poller.PollerRequest	createPollerRequest(com.liferay.portal.kernel.poller.PollerHeader pollerHeader, String portletId, Map<String,String> parameterMap, String chunkId, boolean receiveRequest)
protected List<com.liferay.portal.kernel.poller.PollerRequest>	createPollerRequests(com.liferay.portal.kernel.poller.PollerHeader pollerHeader, Map<String,Object>[] pollerRequestChunks, boolean receiveRequest)
protected com.liferay.portal.kernel.json.JSONObject	createPollerResponseHeader(com.liferay.portal.kernel.poller.PollerHeader pollerHeader)
protected void	executePollerRequests(PollerSession pollerSession, List<com.liferay.portal.kernel.poller.PollerRequest> pollerRequests)
protected String	fixPollerRequestString(String pollerRequestString)
com.liferay.portal.kernel.poller.PollerHeader	getPollerHeader(String pollerRequestString)
protected String	getPollerSessionId(com.liferay.portal.kernel.poller.PollerHeader pollerHeader)
protected long	getUserId(long companyId, String userIdString)
protected boolean	isReceiveRequest(String path)
protected boolean	isValidPollerHeader(com.liferay.portal.kernel.poller.PollerHeader pollerHeader)
protected Map<String,String>	parseData(Map<String,Object> pollerRequestChunk)
protected com.liferay.portal.kernel.poller.PollerHeader	parsePollerRequestHeader(Map<String,Object>[] pollerRequestChunks)
protected Map<String,Object>[]	parsePollerRequestParameters(String pollerRequestString)
com.liferay.portal.kernel.json.JSONObject	processRequest(javax.servlet.http.HttpServletRequest request, String pollerRequestString)
void	receive(com.liferay.portal.kernel.messaging.Message message)

Methods inherited from class Object

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

Constructor Detail

PollerRequestHandlerImpl

public PollerRequestHandlerImpl()

Method Detail

getPollerHeader

public com.liferay.portal.kernel.poller.PollerHeader getPollerHeader(String pollerRequestString)

Specified by:

getPollerHeader in interface PollerRequestHandler

processRequest

public com.liferay.portal.kernel.json.JSONObject processRequest(javax.servlet.http.HttpServletRequest request,
                                                                String pollerRequestString)
                                                         throws Exception

Specified by:

processRequest in interface PollerRequestHandler

Throws:

Exception

receive

public void receive(com.liferay.portal.kernel.messaging.Message message)

Specified by:

receive in interface com.liferay.portal.kernel.messaging.MessageListener

createPollerRequest

protected com.liferay.portal.kernel.poller.PollerRequest createPollerRequest(com.liferay.portal.kernel.poller.PollerHeader pollerHeader,
                                                                             String portletId,
                                                                             boolean receiveRequest)
                                                                      throws Exception

Throws:

Exception

createPollerRequest

protected com.liferay.portal.kernel.poller.PollerRequest createPollerRequest(com.liferay.portal.kernel.poller.PollerHeader pollerHeader,
                                                                             String portletId,
                                                                             Map<String,String> parameterMap,
                                                                             String chunkId,
                                                                             boolean receiveRequest)
                                                                      throws Exception

Throws:

Exception

createPollerRequests

protected List<com.liferay.portal.kernel.poller.PollerRequest> createPollerRequests(com.liferay.portal.kernel.poller.PollerHeader pollerHeader,
                                                                                    Map<String,Object>[] pollerRequestChunks,
                                                                                    boolean receiveRequest)
                                                                             throws Exception

Throws:

Exception

createPollerResponseHeader

protected com.liferay.portal.kernel.json.JSONObject createPollerResponseHeader(com.liferay.portal.kernel.poller.PollerHeader pollerHeader)

executePollerRequests

protected void executePollerRequests(PollerSession pollerSession,
                                     List<com.liferay.portal.kernel.poller.PollerRequest> pollerRequests)

fixPollerRequestString

protected String fixPollerRequestString(String pollerRequestString)

getPollerSessionId

protected String getPollerSessionId(com.liferay.portal.kernel.poller.PollerHeader pollerHeader)

getUserId

protected long getUserId(long companyId,
                         String userIdString)

isReceiveRequest

protected boolean isReceiveRequest(String path)

isValidPollerHeader

protected boolean isValidPollerHeader(com.liferay.portal.kernel.poller.PollerHeader pollerHeader)

parseData

protected Map<String,String> parseData(Map<String,Object> pollerRequestChunk)
                                throws Exception

Throws:

Exception

parsePollerRequestHeader

protected com.liferay.portal.kernel.poller.PollerHeader parsePollerRequestHeader(Map<String,Object>[] pollerRequestChunks)

parsePollerRequestParameters

protected Map<String,Object>[] parsePollerRequestParameters(String pollerRequestString)