public class PollerRequestHandlerImpl extends Object implements PollerRequestHandler, com.liferay.portal.kernel.messaging.MessageListener
| Constructor and Description |
|---|
PollerRequestHandlerImpl() |
| 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) |
public com.liferay.portal.kernel.poller.PollerHeader getPollerHeader(String pollerRequestString)
getPollerHeader in interface PollerRequestHandlerpublic com.liferay.portal.kernel.json.JSONObject processRequest(javax.servlet.http.HttpServletRequest request,
String pollerRequestString)
throws Exception
processRequest in interface PollerRequestHandlerExceptionpublic void receive(com.liferay.portal.kernel.messaging.Message message)
receive in interface com.liferay.portal.kernel.messaging.MessageListenerprotected com.liferay.portal.kernel.poller.PollerRequest createPollerRequest(com.liferay.portal.kernel.poller.PollerHeader pollerHeader,
String portletId,
boolean receiveRequest)
throws Exception
Exceptionprotected 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
Exceptionprotected List<com.liferay.portal.kernel.poller.PollerRequest> createPollerRequests(com.liferay.portal.kernel.poller.PollerHeader pollerHeader, Map<String,Object>[] pollerRequestChunks, boolean receiveRequest) throws Exception
Exceptionprotected 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 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) throws Exception
Exceptionprotected com.liferay.portal.kernel.poller.PollerHeader parsePollerRequestHeader(Map<String,Object>[] pollerRequestChunks)