com.liferay.portal.poller
Class PollerRequestHandlerImpl

java.lang.Object
  com.liferay.portal.poller.PollerRequestHandlerImpl

All Implemented Interfaces:

MessageListener, PollerRequestHandler

public class PollerRequestHandlerImpl
extends Object
implements PollerRequestHandler, MessageListener

Constructor Summary

PollerRequestHandlerImpl()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PollerRequestHandlerImpl

public PollerRequestHandlerImpl()

Method Detail

getPollerHeader

public PollerHeader getPollerHeader(String pollerRequestString)

Specified by:

getPollerHeader in interface PollerRequestHandler

processRequest

public JSONObject processRequest(javax.servlet.http.HttpServletRequest request,
                                 String pollerRequestString)
                          throws Exception

Specified by:

processRequest in interface PollerRequestHandler

Throws:

Exception

receive

public void receive(Message message)

Specified by:

receive in interface MessageListener

createPollerRequest

protected PollerRequest createPollerRequest(javax.servlet.http.HttpServletRequest request,
                                            boolean receiveRequest,
                                            PollerHeader pollerHeader,
                                            String portletId)
                                     throws Exception

Throws:

Exception

createPollerRequest

protected PollerRequest createPollerRequest(javax.servlet.http.HttpServletRequest request,
                                            boolean receiveRequest,
                                            PollerHeader pollerHeader,
                                            String portletId,
                                            Map<String,String> parameterMap,
                                            String chunkId)
                                     throws Exception

Throws:

Exception

createPollerRequests

protected List<PollerRequest> createPollerRequests(javax.servlet.http.HttpServletRequest request,
                                                   PollerHeader pollerHeader,
                                                   Map<String,Object>[] pollerRequestChunks,
                                                   boolean receiveRequest)
                                            throws Exception

Throws:

Exception

createPollerResponseHeader

protected JSONObject createPollerResponseHeader(PollerHeader pollerHeader)
                                         throws SystemException

Throws:

SystemException

executePollerRequests

protected void executePollerRequests(PollerSession pollerSession,
                                     List<PollerRequest> pollerRequests)

fixPollerRequestString

protected String fixPollerRequestString(String pollerRequestString)

getPollerSessionId

protected String getPollerSessionId(PollerHeader pollerHeader)

getUserId

protected long getUserId(long companyId,
                         String userIdString)

isReceiveRequest

protected boolean isReceiveRequest(String path)

isValidPollerHeader

protected boolean isValidPollerHeader(PollerHeader pollerHeader)

parseData

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

Throws:

Exception

parsePollerRequestHeader

protected PollerHeader parsePollerRequestHeader(Map<String,Object>[] pollerRequestChunks)

parsePollerRequestParameters

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