org.springframework.integration.control
Class ControlBus

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

All Implemented Interfaces:

org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean

public class ControlBus
extends java.lang.Object
implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.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 java.lang.String	DEFAULT_DOMAIN
static java.lang.String	TARGET_BEAN_NAME

Constructor Summary

ControlBus(javax.management.MBeanServer server)
Create a ControlBus that will register channels and endpoints as MBeans with the given MBeanServer using the default domain name.

ControlBus(javax.management.MBeanServer server, java.lang.String domain)
Create a ControlBus that will register channels and endpoints as MBeans with the given MBeanServer using the specified domain name.

Method Summary

void	afterPropertiesSet()
MessageChannel	getOperationChannel() Returns the channel to which operation-invoking Messages may be sent.
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_DOMAIN

public static final java.lang.String DEFAULT_DOMAIN

See Also:

Constant Field Values

TARGET_BEAN_NAME

public static final java.lang.String TARGET_BEAN_NAME

See Also:

Constant Field Values

Constructor Detail

ControlBus

public ControlBus(javax.management.MBeanServer server)

Create a ControlBus that will register channels and endpoints as MBeans with the given MBeanServer using the default domain name.

See Also:

DEFAULT_DOMAIN

ControlBus

public ControlBus(javax.management.MBeanServer server,
                  java.lang.String domain)

Create a ControlBus that will register channels and endpoints as MBeans with the given MBeanServer using the specified domain name.

Method Detail

getOperationChannel

public MessageChannel 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(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception