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 Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	receive(org.springframework.messaging.Message<List<Map<String,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<List<EngineEvent>>> engineEventsSink)

Method Detail

receive

@StreamListener("graphQLEngineEventsConsumerSource")
public void receive(org.springframework.messaging.Message<List<Map<String,Object>>> input)