org.mule.transport
Class ContinuousPollingReceiverWorker

java.lang.Object
  extended by org.mule.transport.PollingReceiverWorker
      extended by 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
ContinuousPollingReceiverWorker(AbstractPollingMessageReceiver pollingMessageReceiver)
           
 
Method Summary
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


Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.