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

Field Summary

Fields

Modifier and Type	Field	Description
static String	ENGINE_EVENTS_FLUX_SCHEDULER

Constructor Summary

Constructors

Constructor	Description
DefaultEngineEventsConsumerConfiguration(EngineEventsConsumerProperties properties)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<org.springframework.messaging.Message<List<EngineEvent>>>	engineEventsFlux(org.reactivestreams.Publisher<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsPublisher, reactor.core.scheduler.Scheduler engineEventsScheduler)
EngineEventsConsumerMessageHandler	engineEventsMessageHandler(Transformer engineEventsTransformer)
org.reactivestreams.Publisher<org.springframework.messaging.Message<List<EngineEvent>>>	engineEventsPublisher(EngineEventsConsumerMessageHandler engineEventsMessageHandler)
reactor.core.scheduler.Scheduler	engineEventsScheduler()
Transformer	engineEventsTransformer()
RoutingKeyResolver	routingKeyResolver()

Methods inherited from class java.lang.Object

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

Field Detail

ENGINE_EVENTS_FLUX_SCHEDULER

public static final String ENGINE_EVENTS_FLUX_SCHEDULER

See Also:

Constant Field Values

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)

engineEventsPublisher

@Bean
@ConditionalOnMissingBean
public org.reactivestreams.Publisher<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsPublisher(EngineEventsConsumerMessageHandler engineEventsMessageHandler)

engineEventsFlux

@Bean
@ConditionalOnMissingBean
public reactor.core.publisher.Flux<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsFlux(org.reactivestreams.Publisher<org.springframework.messaging.Message<List<EngineEvent>>> engineEventsPublisher,
                                                                                                              reactor.core.scheduler.Scheduler engineEventsScheduler)

engineEventsScheduler

@Bean
@ConditionalOnMissingBean(name="engineEventsScheduler")
public reactor.core.scheduler.Scheduler engineEventsScheduler()