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

Class EngineEventsConsumerAutoConfiguration.EngineEventsFluxProcessorConfiguration

  • All Implemented Interfaces:
    org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle
    Enclosing class:
    EngineEventsConsumerAutoConfiguration
    @Configuration
public static class EngineEventsConsumerAutoConfiguration.EngineEventsFluxProcessorConfiguration
extends java.lang.Object
implements org.springframework.context.SmartLifecycle

    • Field Summary

      • Fields inherited from interface org.springframework.context.SmartLifecycle

        DEFAULT_PHASE

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      reactor.core.publisher.Flux<org.springframework.messaging.Message<java.util.List<EngineEvent>>> engineEventsFlux()  
      reactor.core.publisher.FluxSink<org.springframework.messaging.Message<java.util.List<EngineEvent>>> engineEventsSink()  
      boolean isRunning()  
      void setSubscribers​(java.util.List<org.reactivestreams.Subscriber<org.springframework.messaging.Message<java.util.List<EngineEvent>>>> subscribers)  
      void start()  
      void stop()  

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface org.springframework.context.SmartLifecycle

        getPhase, isAutoStartup, stop

    • Constructor Detail

      • EngineEventsFluxProcessorConfiguration

        @Autowired
public EngineEventsFluxProcessorConfiguration()

    • Method Detail

      • setSubscribers

        @Autowired(required=false)
public void setSubscribers​(java.util.List<org.reactivestreams.Subscriber<org.springframework.messaging.Message<java.util.List<EngineEvent>>>> subscribers)

      • engineEventsFlux

        @Bean
@ConditionalOnMissingBean
public reactor.core.publisher.Flux<org.springframework.messaging.Message<java.util.List<EngineEvent>>> engineEventsFlux()

      • engineEventsSink

        @Bean
@ConditionalOnMissingBean
public reactor.core.publisher.FluxSink<org.springframework.messaging.Message<java.util.List<EngineEvent>>> engineEventsSink()

      • 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