Package org.activiti.cloud.services.notifications.graphql.events.consumer

Class EngineEventsConsumerAutoConfiguration.DefaultEngineEventsConsumerConfiguration

java.lang.Object

org.activiti.cloud.services.notifications.graphql.events.consumer.EngineEventsConsumerAutoConfiguration.DefaultEngineEventsConsumerConfiguration

Enclosing class:

EngineEventsConsumerAutoConfiguration

@Configuration
public static class EngineEventsConsumerAutoConfiguration.DefaultEngineEventsConsumerConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
DefaultEngineEventsConsumerConfiguration(EngineEventsConsumerProperties properties)

Method Summary

Modifier and Type	Method	Description
EngineEventsConsumerMessageHandler	engineEventsMessageHandler(Transformer engineEventsTransformer, reactor.core.publisher.FluxSink<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsSink)
Transformer	engineEventsTransformer()
RoutingKeyResolver	routingKeyResolver()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEngineEventsConsumerConfiguration

@Autowired
public DefaultEngineEventsConsumerConfiguration(EngineEventsConsumerProperties properties)

Method Detail

routingKeyResolver

@Bean
@ConditionalOnMissingBean
public RoutingKeyResolver routingKeyResolver()

engineEventsTransformer

@Bean
@ConditionalOnMissingBean
public Transformer engineEventsTransformer()

engineEventsMessageHandler

@Bean
@ConditionalOnMissingBean
public EngineEventsConsumerMessageHandler engineEventsMessageHandler(Transformer engineEventsTransformer,
                                                                     reactor.core.publisher.FluxSink<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsSink)