org.apache.camel.management.mbean
Class ManagedThreadPool

java.lang.Object
  extended by org.apache.camel.management.mbean.ManagedThreadPool

@ManagedResource(description="Managed ThreadPool")
public class ManagedThreadPool
extends Object

Version:

Constructor Summary
ManagedThreadPool(CamelContext camelContext, ThreadPoolExecutor threadPool, String id, String sourceId, String routeId, String threadPoolProfileId)
           
 
Method Summary
 int getActiveCount()
           
 long getCompletedTaskCount()
           
 CamelContext getContext()
           
 int getCorePoolSize()
           
 String getId()
           
 long getKeepAliveTime()
           
 int getLargestPoolSize()
           
 int getMaximumPoolSize()
           
 int getPoolSize()
           
 String getRouteId()
           
 String getSourceId()
           
 long getTaskCount()
           
 long getTaskQueueSize()
           
 ThreadPoolExecutor getThreadPool()
           
 String getThreadPoolProfileId()
           
 void init(ManagementStrategy strategy)
           
 boolean isShutdown()
           
 boolean isTaskQueueEmpty()
           
 void setCorePoolSize(int corePoolSize)
           
 void setKeepAliveTime(int keepAliveTimeInSeconds)
           
 void setMaximumPoolSize(int maximumPoolSize)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ManagedThreadPool

public ManagedThreadPool(CamelContext camelContext,
                         ThreadPoolExecutor threadPool,
                         String id,
                         String sourceId,
                         String routeId,
                         String threadPoolProfileId)
Method Detail

init

public void init(ManagementStrategy strategy)

getContext

public CamelContext getContext()

getThreadPool

public ThreadPoolExecutor getThreadPool()

getId

@ManagedAttribute(description="Thread Pool id")
public String getId()

getSourceId

@ManagedAttribute(description="Id of source for creating Thread Pool")
public String getSourceId()

getRouteId

@ManagedAttribute(description="Route id for the source, which created the Thread Pool")
public String getRouteId()

getThreadPoolProfileId

@ManagedAttribute(description="Id of the thread pool profile which this pool is based upon")
public String getThreadPoolProfileId()

getCorePoolSize

@ManagedAttribute(description="Core pool size")
public int getCorePoolSize()

setCorePoolSize

@ManagedAttribute(description="Core pool size")
public void setCorePoolSize(int corePoolSize)

getPoolSize

@ManagedAttribute(description="Pool size")
public int getPoolSize()

getMaximumPoolSize

@ManagedAttribute(description="Maximum pool size")
public int getMaximumPoolSize()

setMaximumPoolSize

@ManagedAttribute(description="Maximum pool size")
public void setMaximumPoolSize(int maximumPoolSize)

getLargestPoolSize

@ManagedAttribute(description="Largest pool size")
public int getLargestPoolSize()

getActiveCount

@ManagedAttribute(description="Active count")
public int getActiveCount()

getTaskCount

@ManagedAttribute(description="Task count")
public long getTaskCount()

getCompletedTaskCount

@ManagedAttribute(description="Completed task count")
public long getCompletedTaskCount()

getTaskQueueSize

@ManagedAttribute(description="Task queue size")
public long getTaskQueueSize()

isTaskQueueEmpty

@ManagedAttribute(description="Is task queue empty")
public boolean isTaskQueueEmpty()

getKeepAliveTime

@ManagedAttribute(description="Keep alive time in seconds")
public long getKeepAliveTime()

setKeepAliveTime

@ManagedAttribute(description="Keep alive time in seconds")
public void setKeepAliveTime(int keepAliveTimeInSeconds)

isShutdown

@ManagedAttribute(description="Is shutdown")
public boolean isShutdown()


Apache CAMEL