org.mule.impl.work
Class MuleWorkManager

java.lang.Object
  extended byorg.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
 
Constructor Summary
MuleWorkManager()
          Create a MuleWorkManager.
MuleWorkManager(ThreadingProfile profile, java.lang.String name)
           
 
Method Summary
 void dispose()
          A lifecycle method where implementor should fee up any resources If an exception is thrown it should just be logged and processing should continue.
 void doWork(Work work)
           
 void doWork(Work work, long startTimeout, ExecutionContext execContext, WorkListener workListener)
           
 int getScheduledMaximumPoolSize()
           
 int getScheduledThreadCount()
           
 int getStartMaximumPoolSize()
           
 int getStartThreadCount()
           
 int getSyncMaximumPoolSize()
           
 int getSyncThreadCount()
           
 XATerminator getXATerminator()
           
 void scheduleWork(Work work)
           
 void scheduleWork(Work work, long startTimeout, ExecutionContext execContext, WorkListener workListener)
           
 void setScheduledMaximumPoolSize(int maxSize)
           
 void setStartMaximumPoolSize(int maxSize)
           
 void setSyncMaximumPoolSize(int maxSize)
           
 void start()
           
 long startWork(Work work)
           
 long startWork(Work work, long startTimeout, ExecutionContext execContext, WorkListener workListener)
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

logger

protected static transient Log logger
logger used by this class

Constructor Detail

MuleWorkManager

public MuleWorkManager()
Create a MuleWorkManager.


MuleWorkManager

public MuleWorkManager(ThreadingProfile profile,
                       java.lang.String name)
Method Detail

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.