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

Class EngineEventsConsumerMessageHandler

java.lang.Object

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

public class EngineEventsConsumerMessageHandler
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
EngineEventsConsumerMessageHandler(Transformer transformer, reactor.core.publisher.FluxSink<org.springframework.messaging.Message<java.util.List<EngineEvent>>> engineEventsSink)

Method Summary

Modifier and Type	Method	Description
void	receive(reactor.core.publisher.Flux<org.springframework.messaging.Message<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>>> input)

Methods inherited from class java.lang.Object

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

Constructor Detail

EngineEventsConsumerMessageHandler

public EngineEventsConsumerMessageHandler(Transformer transformer,
                                          reactor.core.publisher.FluxSink<org.springframework.messaging.Message<java.util.List<EngineEvent>>> engineEventsSink)

Method Detail

receive

@StreamListener
public void receive(@Input("graphQLEngineEventsConsumerSource")
                    reactor.core.publisher.Flux<org.springframework.messaging.Message<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>>> input)