| java.lang.Object org.mule.transport.AbstractMessageReceiver org.mule.transport.AbstractPollingMessageReceiver
All known Subclasses: org.mule.transport.email.RetrieveMessageReceiver, org.mule.transport.stdio.StdioMessageReceiver, org.mule.transport.http.PollingHttpMessageReceiver, org.mule.transport.ftp.FtpMessageReceiver, org.mule.transport.rmi.RmiMessageReceiver, org.mule.transport.TransactedPollingMessageReceiver, org.mule.transport.file.FileMessageReceiver,
AbstractPollingMessageReceiver | abstract public class AbstractPollingMessageReceiver extends AbstractMessageReceiver (Code) | | AbstractPollingMessageReceiver implements a base class for polling
message receivers. The receiver provides a
AbstractPollingMessageReceiver.poll() method that implementations
must implement to execute their custom code. Note that the receiver will not poll if
the associated connector is not started.
|
DEFAULT_POLL_FREQUENCY | final public static long DEFAULT_POLL_FREQUENCY(Code) | | |
DEFAULT_POLL_TIMEUNIT | final public static TimeUnit DEFAULT_POLL_TIMEUNIT(Code) | | |
DEFAULT_STARTUP_DELAY | final public static long DEFAULT_STARTUP_DELAY(Code) | | |
getFrequency | public long getFrequency()(Code) | | |
getTimeUnit | public TimeUnit getTimeUnit()(Code) | | |
schedule | protected void schedule() throws RejectedExecutionException, NullPointerException, IllegalArgumentException(Code) | | This method registers this receiver for periodic polling ticks with the connectors
scheduler. Subclasses can override this in case they want to handle their polling
differently.
throws: RejectedExecutionException - throws: NullPointerException - throws: IllegalArgumentException - See Also: ScheduledExecutorService.scheduleWithFixedDelay(RunnablelonglongTimeUnit) |
setFrequency | public void setFrequency(long value)(Code) | | |
setTimeUnit | public void setTimeUnit(TimeUnit timeUnit)(Code) | | |
Methods inherited from org.mule.transport.AbstractMessageReceiver | public void connect() throws Exception(Code)(Java Doc) public void disconnect() throws Exception(Code)(Java Doc) final public void dispose()(Code)(Java Doc) abstract protected void doConnect() throws Exception(Code)(Java Doc) abstract protected void doDisconnect() throws Exception(Code)(Java Doc) abstract protected void doDispose()(Code)(Java Doc) protected void doInitialise() throws InitialisationException(Code)(Java Doc) abstract protected void doStart() throws MuleException(Code)(Java Doc) abstract protected void doStop() throws MuleException(Code)(Java Doc) protected String getConnectEventId()(Code)(Java Doc) public String getConnectionDescription()(Code)(Java Doc) public Connector getConnector()(Code)(Java Doc) public InboundEndpoint getEndpoint()(Code)(Java Doc) public EndpointURI getEndpointURI()(Code)(Java Doc) public InternalMessageListener getListener()(Code)(Java Doc) public String getReceiverKey()(Code)(Java Doc) public Service getService()(Code)(Java Doc) protected WorkManager getWorkManager()(Code)(Java Doc) public void handleException(Exception exception)(Code)(Java Doc) protected MuleMessage handleUnacceptedFilter(MuleMessage message)(Code)(Java Doc) public LifecycleTransitionResult initialise() throws InitialisationException(Code)(Java Doc) final public boolean isConnected()(Code)(Java Doc) final public MuleMessage routeMessage(MuleMessage message) throws MuleException(Code)(Java Doc) final public MuleMessage routeMessage(MuleMessage message, boolean synchronous) throws MuleException(Code)(Java Doc) final public MuleMessage routeMessage(MuleMessage message, Transaction trans, boolean synchronous) throws MuleException(Code)(Java Doc) final public MuleMessage routeMessage(MuleMessage message, OutputStream outputStream) throws MuleException(Code)(Java Doc) final public MuleMessage routeMessage(MuleMessage message, boolean synchronous, OutputStream outputStream) throws MuleException(Code)(Java Doc) final public MuleMessage routeMessage(MuleMessage message, Transaction trans, boolean synchronous, OutputStream outputStream) throws MuleException(Code)(Java Doc) public void setConnector(Connector connector)(Code)(Java Doc) public void setEndpoint(InboundEndpoint endpoint)(Code)(Java Doc) protected void setExceptionDetails(MuleMessage message, Throwable exception)(Code)(Java Doc) public void setListener(InternalMessageListener listener)(Code)(Java Doc) public void setReceiverKey(String receiverKey)(Code)(Java Doc) public void setService(Service service)(Code)(Java Doc) protected void setWorkManager(WorkManager workManager)(Code)(Java Doc) final public LifecycleTransitionResult start() throws MuleException(Code)(Java Doc) final public LifecycleTransitionResult stop()(Code)(Java Doc) public String toString()(Code)(Java Doc)
|
|
|