org.axonframework.boot.autoconfig

Class JGroupsAutoConfiguration

java.lang.Object

org.axonframework.boot.autoconfig.JGroupsAutoConfiguration

@Configuration
 @ConditionalOnExpression(value="${axon.distributed.enabled:false} || ${axon.distributed.jgroups.enabled:false}")
 @ConditionalOnClass(name={"org.axonframework.jgroups.commandhandling.JGroupsConnector","org.jgroups.JChannel"})
public class JGroupsAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor and Description
JGroupsAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
org.jgroups.stack.GossipRouter	gossipRouter()
JGroupsConnectorFactoryBean	jgroupsConnectorFactoryBean(Serializer messageSerializer, CommandBus localSegment, RoutingStrategy routingStrategy, ConsistentHashChangeListener consistentHashChangeListener)

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupsAutoConfiguration

public JGroupsAutoConfiguration()

Method Detail

gossipRouter

@ConditionalOnProperty(value="axon.distributed.jgroups.gossip.autoStart")
 @Bean(destroyMethod="stop")
public org.jgroups.stack.GossipRouter gossipRouter()

jgroupsConnectorFactoryBean

@ConditionalOnMissingBean(value={CommandRouter.class,CommandBusConnector.class})
 @Bean
public JGroupsConnectorFactoryBean jgroupsConnectorFactoryBean(@Qualifier(value="messageSerializer")
                                                                                                                                                         Serializer messageSerializer,
                                                                                                                                                         @Qualifier(value="localSegment")
                                                                                                                                                         CommandBus localSegment,
                                                                                                                                                         RoutingStrategy routingStrategy,
                                                                                                                                                         @Autowired(required=false)
                                                                                                                                                         ConsistentHashChangeListener consistentHashChangeListener)