org.mule.transport
Class PollingReceiverWorker

java.lang.Object
  org.mule.transport.PollingReceiverWorker

All Implemented Interfaces:

Runnable, javax.resource.spi.work.Work

Direct Known Subclasses:

ContinuousPollingReceiverWorker

public class PollingReceiverWorker
extends Object
implements javax.resource.spi.work.Work

Field Summary

protected AbstractPollingMessageReceiver	receiver
protected boolean	running

Constructor Summary

PollingReceiverWorker(AbstractPollingMessageReceiver pollingMessageReceiver)

Method Summary

AbstractPollingMessageReceiver	getReceiver()
boolean	isRunning()
protected void	poll()
void	release()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

receiver

protected final AbstractPollingMessageReceiver receiver

running

protected volatile boolean running

Constructor Detail

PollingReceiverWorker

public PollingReceiverWorker(AbstractPollingMessageReceiver pollingMessageReceiver)

Method Detail

getReceiver

public AbstractPollingMessageReceiver getReceiver()

isRunning

public boolean isRunning()

run

public void run()

Specified by:

run in interface Runnable

poll

protected void poll()
             throws Exception

Throws:

Exception

release

public void release()

Specified by:

release in interface javax.resource.spi.work.Work