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

java.lang.Object
  org.kuali.rice.core.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 ServiceBasedServiceDefinitionRegisterer	defRegisterer
private static org.apache.log4j.Logger	LOG

Constructor Summary

BusAdminServiceImpl()

Method Summary

void	forward(PersistedMessage message) Forward the given message to this service for processing.
void	ping()
void	setConfigProperty(String propertyName, String propertyValue)
void	setCorePoolSize(int corePoolSize)
void	setMaximumPoolSize(int maxPoolSize)
void	start()
void	stop()

Methods inherited from class org.kuali.rice.core.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

defRegisterer

private ServiceBasedServiceDefinitionRegisterer defRegisterer

Constructor Detail

BusAdminServiceImpl

public BusAdminServiceImpl()

Method Detail

forward

public void forward(PersistedMessage message)
             throws Exception

Description copied from interface: BusAdminService

Forward the given message to this service for processing.

Specified by:

forward in interface BusAdminService

Throws:

Exception

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