org.mule.transport
Class ConcurrentWorkTracker
java.lang.Object
org.mule.transport.ConcurrentWorkTracker
- All Implemented Interfaces:
- Disposable, WorkTracker
public class ConcurrentWorkTracker
- extends Object
- implements WorkTracker
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected static final Log logger
ConcurrentWorkTracker
public ConcurrentWorkTracker()
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
Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.