public class PollingHttpMessageReceiver extends AbstractPollingMessageReceiver
Modifier and Type | Field and Description |
---|---|
protected boolean |
checkEtag |
protected boolean |
discardEmptyContent |
protected String |
etag |
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
PollingHttpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect() |
void |
doDisconnect() |
protected void |
doDispose() |
void |
poll() |
protected boolean |
pollOnPrimaryInstanceOnly()
If this returns true for a transport, polling for that transport takes place only on the primary instance.
|
protected void |
setupFromConnector(Connector connector) |
createWork, disableNativeScheduling, doStart, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, schedule, setFrequency, setTimeUnit, unschedule
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
protected String etag
protected boolean checkEtag
protected boolean discardEmptyContent
public PollingHttpMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected boolean pollOnPrimaryInstanceOnly()
AbstractPollingMessageReceiver
pollOnPrimaryInstanceOnly
in class AbstractPollingMessageReceiver
protected void setupFromConnector(Connector connector) throws CreateException
CreateException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
public void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
public void poll() throws Exception
poll
in class AbstractPollingMessageReceiver
Exception
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.