Uses of Class
org.eclipse.microprofile.reactive.messaging.Incoming

Packages that use Incoming

Package	Description
acme
awssns
gcp.pubsub
io.smallrye.reactive.messaging
io.smallrye.reactive.messaging.annotations
io.smallrye.reactive.messaging.example.eventclouds

Uses of Incoming in acme

Methods in acme with annotations of type Incoming

Modifier and Type	Method	Description
CompletionStage<Void>	Receiver.consume(KafkaRecord<String,String> message)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String>	Main.filter(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> input)
void	Main.sink(String word)
CompletionStage<Void>	MqttServerQuickstart.source(MqttMessage message)
String	Main.toUpperCase(String payload)

Uses of Incoming in awssns

Methods in awssns with annotations of type Incoming

Modifier and Type	Method	Description
CompletionStage<Void>	Receiver.consume(Message<String> message)

Uses of Incoming in gcp.pubsub

Methods in gcp.pubsub with annotations of type Incoming

Modifier and Type	Method	Description
CompletionStage<Void>	Receiver.consume(PubSubMessage message)

Uses of Incoming in io.smallrye.reactive.messaging

Method parameters in io.smallrye.reactive.messaging with type arguments of type Incoming

Modifier and Type	Method	Description
void	DefaultMediatorConfiguration.compute(List<Incoming> incomings, Outgoing outgoing, Blocking blocking)

Uses of Incoming in io.smallrye.reactive.messaging.annotations

Methods in io.smallrye.reactive.messaging.annotations that return Incoming

Modifier and Type	Method	Description
Incoming[]	value()

Uses of Incoming in io.smallrye.reactive.messaging.example.eventclouds

Methods in io.smallrye.reactive.messaging.example.eventclouds with annotations of type Incoming

Modifier and Type	Method	Description
CloudEventMessage<String>	MyCloudEventProcessor.process(CloudEventMessage<String> message)
void	MyCloudEventSink.receive(String payload)