org.mule.transport

Class ContinuousPollingReceiverWorker

java.lang.Object

org.mule.transport.PollingReceiverWorker

org.mule.transport.ContinuousPollingReceiverWorker

All Implemented Interfaces:

Runnable, javax.resource.spi.work.Work

public class ContinuousPollingReceiverWorker
extends PollingReceiverWorker

Bypass the regular scheduling mechanism in order to minimize latency and maximize throughput for transports which have low or no cost for performing a poll operation (such as an in-memory queue).

Field Summary

Fields inherited from class org.mule.transport.PollingReceiverWorker

receiver, running

Constructor Summary

Constructors

Constructor and Description
ContinuousPollingReceiverWorker(AbstractPollingMessageReceiver pollingMessageReceiver)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	poll()

Methods inherited from class org.mule.transport.PollingReceiverWorker

getReceiver, isRunning, release, run

Methods inherited from class java.lang.Object

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

Constructor Detail

ContinuousPollingReceiverWorker

public ContinuousPollingReceiverWorker(AbstractPollingMessageReceiver pollingMessageReceiver)

Method Detail

poll

protected void poll()
             throws Exception

Overrides:

poll in class PollingReceiverWorker

Throws:

Exception