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

Packages that use Incoming

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

Uses of Incoming in acme

Methods in acme with annotations of type Incoming

Modifier and Type	Method and 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 and 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 and Description
CompletionStage<Void>	Receiver.consume(PubSubMessage message)

Uses of Incoming in inbound

Methods in inbound with annotations of type Incoming

Modifier and Type	Method and Description
void	KafkaPriceConsumer.consume(double price)
CompletionStage<Void>	KafkaPriceMessageConsumer.consume(Message<Double> price)

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 and Description
void	DefaultMediatorConfiguration.compute(List<Incoming> incomings, Outgoing outgoing, Blocking blocking)

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 and Description
CloudEventMessage<String>	MyCloudEventProcessor.process(CloudEventMessage<String> message)
void	MyCloudEventSink.receive(String payload)