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

All Implemented Interfaces:

EngineEventsConsumerChannels

Enclosing class:

EngineEventsConsumerAutoConfiguration

@Configuration
public static class EngineEventsConsumerAutoConfiguration.DefaultEngineEventsConsumerConfiguration
extends Object
implements EngineEventsConsumerChannels

Field Summary

Fields

Modifier and Type	Field	Description
static String	ENGINE_EVENTS_FLUX_SCHEDULER

Fields inherited from interface org.activiti.cloud.services.notifications.graphql.events.consumer.EngineEventsConsumerChannels

SOURCE

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, org.springframework.messaging.SubscribableChannel source)
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

Methods inherited from interface org.activiti.cloud.services.notifications.graphql.events.consumer.EngineEventsConsumerChannels

input

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,
                                                                                                                     @Qualifier("graphQLEngineEventsConsumerSource")
                                                                                                                     org.springframework.messaging.SubscribableChannel source)

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()