org.mule.transport

Class ConcurrentWorkTracker

java.lang.Object

org.mule.transport.ConcurrentWorkTracker

All Implemented Interfaces:

Disposable, WorkTracker

public class ConcurrentWorkTracker
extends Object
implements WorkTracker

Field Summary

Fields

Modifier and Type	Field and Description
protected static Log	logger

Fields inherited from interface org.mule.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
ConcurrentWorkTracker()

Method Summary

Methods

Modifier and Type	Method and Description
void	addWork(Runnable work) Adds a work for tracking.
void	dispose() A lifecycle method where implementor should free up any resources.
List<Runnable>	pendingWorks() Returns a list of works that are not completed.
void	removeWork(Runnable work) Removes a work from tracking.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final Log logger

Constructor Detail

ConcurrentWorkTracker

public ConcurrentWorkTracker()

Method Detail

pendingWorks

public List<Runnable> pendingWorks()

Description copied from interface: WorkTracker

Returns a list of works that are not completed.

Specified by:

pendingWorks in interface WorkTracker

Returns:

an immutable list of works

addWork

public void addWork(Runnable work)

Description copied from interface: WorkTracker

Adds a work for tracking.

Specified by:

addWork in interface WorkTracker

Parameters:

work - non null work.

removeWork

public void removeWork(Runnable work)

Description copied from interface: WorkTracker

Removes a work from tracking.

Specified by:

removeWork in interface WorkTracker

Parameters:

work - non null work

dispose

public void dispose()

Description copied from interface: Disposable

A lifecycle method where implementor should free up any resources. If an exception is thrown it should just be logged and processing should continue. This method should not throw Runtime exceptions.

Specified by:

dispose in interface Disposable