org.mule.impl.work
Class MuleWorkManager
java.lang.Object
org.mule.impl.work.MuleWorkManager
- All Implemented Interfaces:
- Disposable, Lifecycle, Startable, Stoppable, UMOWorkManager
- public class MuleWorkManager
- extends java.lang.Object
- implements UMOWorkManager
MuleWorkManager
is a Jca Work manager implementation used to
manage thread allocation for Mule components and connectors
This code has been adapted from the Geronimo implementation, and the different
pool executors have be used directly from Geronimo
- Version:
- $Revision: 1.3 $
- Author:
- Ross Mason
Field Summary |
protected static Log |
logger
logger used by this class |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected static transient Log logger
- logger used by this class
MuleWorkManager
public MuleWorkManager()
- Create a MuleWorkManager.
MuleWorkManager
public MuleWorkManager(ThreadingProfile profile,
java.lang.String name)
start
public void start()
throws UMOException
- Specified by:
start
in interface Startable
- Throws:
UMOException
stop
public void stop()
throws UMOException
- Specified by:
stop
in interface Stoppable
- Throws:
UMOException
dispose
public void dispose()
- Description copied from interface:
Disposable
- A lifecycle method where implementor should fee 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
getXATerminator
public XATerminator getXATerminator()
getSyncThreadCount
public int getSyncThreadCount()
getSyncMaximumPoolSize
public int getSyncMaximumPoolSize()
setSyncMaximumPoolSize
public void setSyncMaximumPoolSize(int maxSize)
getStartThreadCount
public int getStartThreadCount()
getStartMaximumPoolSize
public int getStartMaximumPoolSize()
setStartMaximumPoolSize
public void setStartMaximumPoolSize(int maxSize)
getScheduledThreadCount
public int getScheduledThreadCount()
getScheduledMaximumPoolSize
public int getScheduledMaximumPoolSize()
setScheduledMaximumPoolSize
public void setScheduledMaximumPoolSize(int maxSize)
doWork
public void doWork(Work work)
throws WorkException
- Throws:
WorkException
doWork
public void doWork(Work work,
long startTimeout,
ExecutionContext execContext,
WorkListener workListener)
throws WorkException
- Throws:
WorkException
startWork
public long startWork(Work work)
throws WorkException
- Throws:
WorkException
startWork
public long startWork(Work work,
long startTimeout,
ExecutionContext execContext,
WorkListener workListener)
throws WorkException
- Throws:
WorkException
scheduleWork
public void scheduleWork(Work work)
throws WorkException
- Throws:
WorkException
scheduleWork
public void scheduleWork(Work work,
long startTimeout,
ExecutionContext execContext,
WorkListener workListener)
throws WorkException
- Throws:
WorkException
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.