org.kuali.rice.ksb.messaging.service.impl
Class BusAdminServiceImpl

java.lang.Object
  org.kuali.rice.core.api.lifecycle.BaseLifecycle
      org.kuali.rice.ksb.messaging.service.impl.BusAdminServiceImpl

All Implemented Interfaces:

Lifecycle, BusAdminService

public class BusAdminServiceImpl
extends BaseLifecycle
implements BusAdminService

Implementation of the Bus Admin service.

Author:

Kuali Rice Team (rice.collab@kuali.org)

Field Summary

private static org.apache.log4j.Logger	LOG
private KSBThreadPool	threadPool

Constructor Summary

BusAdminServiceImpl()

Method Summary

protected KSBThreadPool	getThreadPool()
void	ping()
void	setConfigProperty(String propertyName, String propertyValue)
void	setCorePoolSize(int corePoolSize)
void	setMaximumPoolSize(int maxPoolSize)
void	setThreadPool(KSBThreadPool threadPool)
void	start()
void	stop()

Methods inherited from class org.kuali.rice.core.api.lifecycle.BaseLifecycle

isStarted, setStarted

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.apache.log4j.Logger LOG

threadPool

private KSBThreadPool threadPool

Constructor Detail

BusAdminServiceImpl

public BusAdminServiceImpl()

Method Detail

setThreadPool

public void setThreadPool(KSBThreadPool threadPool)

getThreadPool

protected KSBThreadPool getThreadPool()

ping

public void ping()

Specified by:

ping in interface BusAdminService

setCorePoolSize

public void setCorePoolSize(int corePoolSize)

Specified by:

setCorePoolSize in interface BusAdminService

setMaximumPoolSize

public void setMaximumPoolSize(int maxPoolSize)

Specified by:

setMaximumPoolSize in interface BusAdminService

setConfigProperty

public void setConfigProperty(String propertyName,
                              String propertyValue)

Specified by:

setConfigProperty in interface BusAdminService

start

public void start()
           throws Exception

Specified by:

start in interface Lifecycle

Overrides:

start in class BaseLifecycle

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Lifecycle

Overrides:

stop in class BaseLifecycle

Throws:

Exception