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

Fields

Modifier and Type	Field and Description
protected AbstractPollingMessageReceiver	receiver
protected boolean	running

Constructor Summary

Constructors

Constructor and Description
PollingReceiverWorker(AbstractPollingMessageReceiver pollingMessageReceiver)

Method Summary

Methods

Modifier and Type	Method and Description
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