org.axonframework.spring.commandhandling.distributed.jgroups

Class JGroupsConnectorFactoryBean

java.lang.Object

org.axonframework.spring.commandhandling.distributed.jgroups.JGroupsConnectorFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.FactoryBean<JGroupsConnector>, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class JGroupsConnectorFactoryBean
extends Object
implements org.springframework.beans.factory.FactoryBean<JGroupsConnector>, org.springframework.beans.factory.InitializingBean, org.springframework.context.SmartLifecycle, org.springframework.beans.factory.BeanNameAware, org.springframework.context.ApplicationContextAware

Spring Factory bean that creates a JGroupsConnector and starts it when the application context is started. This bean must be defined as a top-level bean.

Since:

2.0

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
JGroupsConnectorFactoryBean()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
JGroupsConnector	getObject()
Class<?>	getObjectType()
int	getPhase()
protected JGroupsConnector	instantiateConnector(CommandBus localSegment, org.jgroups.JChannel channel, String clusterName, Serializer serializer, RoutingStrategy routingStrategy)
boolean	isAutoStartup()
boolean	isRunning()
boolean	isSingleton()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setBeanName(String name)
void	setChannelFactory(JChannelFactory channelFactory) Sets the JChannelFactory that allows programmatic definition of the JChannel.
void	setChannelName(String channelName) Optionally sets the logical channel name of the channel.
void	setClusterName(String clusterName) Sets the name of the cluster to subscribe to.
void	setConfiguration(String configuration) Sets the JGroups configuration file to load.
void	setConsistentHashChangeListener(ConsistentHashChangeListener consistentHashChangeListener)
void	setInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> interceptors) Sets the interceptor to use in the default local segment (a SimpleCommandBus).
void	setJoinTimeout(long joinTimeout) Sets the number of milliseconds to wait for this member to join the group.
void	setLocalSegment(CommandBus localSegment) Sets the CommandBus instance on which local commands must be dispatched.
void	setPhase(int phase) Sets the phase in which this bean must be started.
void	setRegisterMBean(boolean registerMBean) Registers the JChannel monitoring bean after the channel has connected.
void	setRoutingStrategy(RoutingStrategy routingStrategy) Sets the RoutingStrategy that the JGroupsConnector will use to determine to which endpoint a message should be routed.
void	setSerializer(Serializer serializer) Sets the serializer used to serialize events before they are dispatched to the destination.
void	start()
void	stop()
void	stop(Runnable callback)

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupsConnectorFactoryBean

public JGroupsConnectorFactoryBean()

Method Detail

getObject

public JGroupsConnector getObject()

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<JGroupsConnector>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<JGroupsConnector>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<JGroupsConnector>

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

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

Throws:

Exception

instantiateConnector

protected JGroupsConnector instantiateConnector(CommandBus localSegment,
                                                org.jgroups.JChannel channel,
                                                String clusterName,
                                                Serializer serializer,
                                                RoutingStrategy routingStrategy)

setSerializer

public void setSerializer(Serializer serializer)

Sets the serializer used to serialize events before they are dispatched to the destination. All members connected to the same channel must use compatible serializers.

Default to an autowired Serializer.

Parameters:

serializer - the serializer to serialize commands with

setConfiguration

public void setConfiguration(String configuration)

Sets the JGroups configuration file to load. Defaults to configuration using TCP with multicast discovery (tcp_mcast.xml). Alternatively the JChannel can be instantiated programatically by setting the JChannelFactory.

Parameters:

configuration - the JGroups configuration file

setRoutingStrategy

public void setRoutingStrategy(RoutingStrategy routingStrategy)

Sets the RoutingStrategy that the JGroupsConnector will use to determine to which endpoint a message should be routed.

Parameters:

routingStrategy - the routing strategy of the connector

setChannelFactory

public void setChannelFactory(JChannelFactory channelFactory)

Sets the JChannelFactory that allows programmatic definition of the JChannel.

Parameters:

channelFactory - The factory that creates the JChannel

setClusterName

public void setClusterName(String clusterName)

Sets the name of the cluster to subscribe to. The Connector will only connect to other instances with the same cluster name. Defaults to the bean name.

Parameters:

clusterName - The name of the cluster to connect to

setChannelName

public void setChannelName(String channelName)

Optionally sets the logical channel name of the channel. If not provided JGroups will generate a default name.

Note that each member of a cluster should have a unique channel name.

Parameters:

channelName - The logical name to give to the channel

setJoinTimeout

public void setJoinTimeout(long joinTimeout)

Sets the number of milliseconds to wait for this member to join the group. Setting this to a non-negative number will cause the start() method to block for at most the given number of milliseconds. After that timeout, attempts to join the cluster will be performed on the background.

Setting a negative value will cause the start() method to wait until the member joined the cluster.

Defaults to -1, which causes the start() to wait indefinitely, until the member has joined the cluster.

Parameters:

joinTimeout - The number of milliseconds to wait for the member to join the cluster

setLocalSegment

public void setLocalSegment(CommandBus localSegment)

Sets the CommandBus instance on which local commands must be dispatched. Defaults to a SimpleCommandBus.

Parameters:

localSegment - the CommandBus instance to dispatch local messages on

setInterceptors

public void setInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> interceptors)

Sets the interceptor to use in the default local segment (a SimpleCommandBus). When providing a custom local segment (setLocalSegment(org.axonframework.commandhandling.CommandBus)), this configuration is ignored.

Parameters:

interceptors - the list of interceptors (in order) for the local segment

setRegisterMBean

public void setRegisterMBean(boolean registerMBean)

Registers the JChannel monitoring bean after the channel has connected. Defaults to false.

Parameters:

registerMBean - if true the JGroups channel will be registered with the MBeanServer

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

setPhase

public void setPhase(int phase)

Sets the phase in which this bean must be started. Defaults to Integer.MAX_VALUE, which ensures the Connector is started when other beans have been initialized.

Parameters:

phase - the phase in which the JGroups connector must be started.

See Also:

SmartLifecycle

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

setConsistentHashChangeListener

public void setConsistentHashChangeListener(ConsistentHashChangeListener consistentHashChangeListener)