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
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 |
PollerRequestHandlerImpl
public PollerRequestHandlerImpl()
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)