org.springframework.integration.control
Class ControlBus

java.lang.Object
  org.springframework.integration.control.ControlBus

All Implemented Interfaces:

BeanFactoryAware, InitializingBean

public class ControlBus
extends Object
implements BeanFactoryAware, InitializingBean

JMX-based Control Bus implementation. Exports all channel and endpoint beans from a given BeanFactory as MBeans.

Since:

2.0

Author:

Mark Fisher

Field Summary

static String

TARGET_BEAN_NAME

Constructor Summary

ControlBus(ObjectNameLocator locator, MBeanServer server, SubscribableChannel operationChannel)
Create a ControlBus.

Method Summary

void	afterPropertiesSet()
SubscribableChannel	getOperationChannel() Returns the channel to which operation-invoking Messages may be sent.
void	setBeanFactory(BeanFactory beanFactory)

Methods inherited from class java.lang.Object

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

Field Detail

TARGET_BEAN_NAME

public static final String TARGET_BEAN_NAME

See Also:

Constant Field Values

Constructor Detail

ControlBus

public ControlBus(ObjectNameLocator locator,
                  MBeanServer server,
                  SubscribableChannel operationChannel)

Create a ControlBus.

Method Detail

getOperationChannel

public SubscribableChannel getOperationChannel()

Returns the channel to which operation-invoking Messages may be sent. Any messages sent to this channel must contain TARGET_BEAN_NAME and JmxHeaders.OPERATION_NAME header values, and the target bean name must match one that has been exported by this Control Bus. If the operation returns a result, the MessageHeaders.REPLY_CHANNEL header is also required.

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception