Uses of Interface
org.eclipse.microprofile.reactive.messaging.Message

Packages that use Message

Package	Description
inbound
io.smallrye.reactive.messaging
io.smallrye.reactive.messaging.amqp
io.smallrye.reactive.messaging.camel
io.smallrye.reactive.messaging.connectors
io.smallrye.reactive.messaging.extension
io.smallrye.reactive.messaging.helpers
io.smallrye.reactive.messaging.impl
io.smallrye.reactive.messaging.jms
io.smallrye.reactive.messaging.kafka
io.smallrye.reactive.messaging.kafka.api
io.smallrye.reactive.messaging.kafka.converters
io.smallrye.reactive.messaging.kafka.i18n
io.smallrye.reactive.messaging.kafka.impl
io.smallrye.reactive.messaging.kafka.impl.ce
io.smallrye.reactive.messaging.metrics
io.smallrye.reactive.messaging.mqtt
io.smallrye.reactive.messaging.rabbitmq
io.smallrye.reactive.messaging.rabbitmq.tracing
org.eclipse.microprofile.reactive.messaging	IMPORTANT This package is a copy from the original package from the specification.
org.eclipse.microprofile.reactive.messaging.spi	The MicroProfile Reactive Messaging API Connector SPI
outbound

Uses of Message in inbound

Methods in inbound with parameters of type Message

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

Uses of Message in io.smallrye.reactive.messaging

Methods in io.smallrye.reactive.messaging with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message<? extends T>> void	MutinyEmitter.send(M msg) Sends a message to the channel.

Methods in io.smallrye.reactive.messaging that return Message

Modifier and Type	Method and Description
Message<?>	MessageConverter.convert(Message<?> in, Type target) Converts the given message in into a Message<T>.
Message<?>	MessageConverter.IdentityConverter.convert(Message<?> in, Type target)

Methods in io.smallrye.reactive.messaging that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	AbstractMediator.convert(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> upstream)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	AbstractMediator.decorate(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> input)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	PublisherDecorator.decorate(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher, String channelName) Decorate a publisher
protected CompletionStage<Message<?>>	AbstractMediator.getAckOrCompletion(Message<?> message)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<Message<?>,Void>	SubscriberMediator.getComputedSubscriber()
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<Message<?>,Void>	AbstractMediator.getComputedSubscriber()
List<org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>>	ChannelRegistry.getPublishers(String name)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	ProcessorMediator.getStream()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	StreamTransformerMediator.getStream()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	AbstractMediator.getStream()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	PublisherMediator.getStream()
List<org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>>	ChannelRegistry.getSubscribers(String name)
protected CompletionStage<Message<?>>	AbstractMediator.handlePreProcessingAck(Message<?> message)
protected Function<Message<?>,? extends CompletionStage<? extends Message<?>>>	AbstractMediator.managePreProcessingAck()
protected Function<Message<?>,? extends CompletionStage<? extends Message<?>>>	AbstractMediator.managePreProcessingAck()
default org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream, boolean broadcast)
default org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber, boolean merge)

Methods in io.smallrye.reactive.messaging with parameters of type Message

Modifier and Type	Method and Description
boolean	MessageConverter.canConvert(Message<?> in, Type target) Checks whether this instance of converter can convert the given message in into a Message<T> with T being the type represented by target.
boolean	MessageConverter.IdentityConverter.canConvert(Message<?> in, Type target)
Message<?>	MessageConverter.convert(Message<?> in, Type target) Converts the given message in into a Message<T>.
Message<?>	MessageConverter.IdentityConverter.convert(Message<?> in, Type target)
static Optional<TracingMetadata>	TracingMetadata.fromMessage(Message<?> message) Retrieves the tracing metadata from inside the Metadata of a Message.
protected CompletionStage<Message<?>>	AbstractMediator.getAckOrCompletion(Message<?> message)
protected CompletionStage<Message<?>>	AbstractMediator.handlePreProcessingAck(Message<?> message)

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

Modifier and Type	Method and Description
void	ProcessorMediator.connectToUpstream(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher)
void	StreamTransformerMediator.connectToUpstream(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher)
void	SubscriberMediator.connectToUpstream(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher)
void	AbstractMediator.connectToUpstream(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	AbstractMediator.convert(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> upstream)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	AbstractMediator.decorate(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> input)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	PublisherDecorator.decorate(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher, String channelName) Decorate a publisher
default org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream, boolean broadcast)
default org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	ChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber, boolean merge)

Uses of Message in io.smallrye.reactive.messaging.amqp

Classes in io.smallrye.reactive.messaging.amqp that implement Message

Modifier and Type	Class and Description
class	AmqpMessage<T>
class	OutgoingAmqpMessage<T>

Methods in io.smallrye.reactive.messaging.amqp that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	AmqpConnector.getPublisherBuilder(org.eclipse.microprofile.config.Config config)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	AmqpConnector.getSubscriberBuilder(org.eclipse.microprofile.config.Config config)

Methods in io.smallrye.reactive.messaging.amqp with parameters of type Message

Modifier and Type	Method and Description
void	AmqpCreditBasedSender.onNext(Message<?> message)

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

Modifier and Type	Method and Description
void	AmqpCreditBasedSender.subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)

Uses of Message in io.smallrye.reactive.messaging.camel

Classes in io.smallrye.reactive.messaging.camel that implement Message

Modifier and Type	Class and Description
class	CamelMessage<T>

Methods in io.smallrye.reactive.messaging.camel that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	CamelConnector.getPublisherBuilder(org.eclipse.microprofile.config.Config config)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	CamelConnector.getSubscriberBuilder(org.eclipse.microprofile.config.Config config)

Uses of Message in io.smallrye.reactive.messaging.connectors

Methods in io.smallrye.reactive.messaging.connectors that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	InMemoryConnector.getPublisherBuilder(org.eclipse.microprofile.config.Config config)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	InMemoryConnector.getSubscriberBuilder(org.eclipse.microprofile.config.Config config)
List<? extends Message<T>>	InMemorySink.received()

Uses of Message in io.smallrye.reactive.messaging.extension

Fields in io.smallrye.reactive.messaging.extension with type parameters of type Message

Modifier and Type	Field and Description
protected AtomicReference<io.smallrye.mutiny.subscription.MultiEmitter<? super Message<? extends T>>>	AbstractEmitter.internal
protected io.smallrye.mutiny.Multi<Message<? extends T>>	AbstractEmitter.publisher

Methods in io.smallrye.reactive.messaging.extension with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message<? extends T>> void	MutinyEmitterImpl.send(M msg)
<M extends Message<? extends T>> void	EmitterImpl.send(M msg)

Methods in io.smallrye.reactive.messaging.extension that return types with arguments of type Message

Modifier and Type	Method and Description
org.reactivestreams.Publisher<Message<? extends T>>	AbstractEmitter.getPublisher()

Methods in io.smallrye.reactive.messaging.extension with parameters of type Message

Modifier and Type	Method and Description
protected void	AbstractEmitter.emit(Message<? extends T> message)

Uses of Message in io.smallrye.reactive.messaging.helpers

Methods in io.smallrye.reactive.messaging.helpers that return types with arguments of type Message

Modifier and Type	Method and Description
static org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	BroadcastHelper.broadcastPublisher(org.reactivestreams.Publisher<? extends Message<?>> publisher, int numberOfSubscriberBeforeConnecting) Wraps an existing Publisher for broadcasting.

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

Modifier and Type	Method and Description
static org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	BroadcastHelper.broadcastPublisher(org.reactivestreams.Publisher<? extends Message<?>> publisher, int numberOfSubscriberBeforeConnecting) Wraps an existing Publisher for broadcasting.

Uses of Message in io.smallrye.reactive.messaging.impl

Methods in io.smallrye.reactive.messaging.impl that return types with arguments of type Message

Modifier and Type	Method and Description
List<org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>>	InternalChannelRegistry.getPublishers(String name)
List<org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>>	InternalChannelRegistry.getSubscribers(String name)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	InternalChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream, boolean broadcast)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	InternalChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber, boolean merge)

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

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	InternalChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream, boolean broadcast)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	InternalChannelRegistry.register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber, boolean merge)

Uses of Message in io.smallrye.reactive.messaging.jms

Classes in io.smallrye.reactive.messaging.jms that implement Message

Modifier and Type	Class and Description
class	IncomingJmsMessage<T>

Methods in io.smallrye.reactive.messaging.jms that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	JmsConnector.getPublisherBuilder(org.eclipse.microprofile.config.Config config)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	JmsConnector.getSubscriberBuilder(org.eclipse.microprofile.config.Config config)

Uses of Message in io.smallrye.reactive.messaging.kafka

Subinterfaces of Message in io.smallrye.reactive.messaging.kafka

Modifier and Type	Interface and Description
interface	KafkaMessage<K,T> Deprecated. Use instead
interface	KafkaRecord<K,T>

Classes in io.smallrye.reactive.messaging.kafka that implement Message

Modifier and Type	Class and Description
class	IncomingKafkaRecord<K,T>
class	OutgoingKafkaRecord<K,T>

Methods in io.smallrye.reactive.messaging.kafka that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	KafkaConnector.getPublisherBuilder(org.eclipse.microprofile.config.Config config)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	KafkaConnector.getSubscriberBuilder(org.eclipse.microprofile.config.Config config)

Methods in io.smallrye.reactive.messaging.kafka with parameters of type Message

Modifier and Type	Method and Description
static <K,T> OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.from(Message<T> message)
static <K,T> OutgoingKafkaRecord<K,T>	KafkaRecord.from(Message<T> message)

Uses of Message in io.smallrye.reactive.messaging.kafka.api

Methods in io.smallrye.reactive.messaging.kafka.api that return Message

Modifier and Type	Method and Description
static <T,K> Message<T>	KafkaMetadataUtil.writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata) Write OutgoingKafkaRecordMetadata to a Message.

Methods in io.smallrye.reactive.messaging.kafka.api with parameters of type Message

Modifier and Type	Method and Description
static Optional<IncomingKafkaRecordMetadata>	KafkaMetadataUtil.readIncomingKafkaMetadata(Message<?> msg) Read IncomingKafkaRecordMetadata from a Message.
static <T,K> Message<T>	KafkaMetadataUtil.writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata) Write OutgoingKafkaRecordMetadata to a Message.

Uses of Message in io.smallrye.reactive.messaging.kafka.converters

Methods in io.smallrye.reactive.messaging.kafka.converters that return Message

Modifier and Type	Method and Description
Message<?>	ConsumerRecordConverter.convert(Message<?> in, Type target)
Message<?>	RecordConverter.convert(Message<?> in, Type target)

Methods in io.smallrye.reactive.messaging.kafka.converters with parameters of type Message

Modifier and Type	Method and Description
boolean	ConsumerRecordConverter.canConvert(Message<?> in, Type target)
boolean	RecordConverter.canConvert(Message<?> in, Type target)
Message<?>	ConsumerRecordConverter.convert(Message<?> in, Type target)
Message<?>	RecordConverter.convert(Message<?> in, Type target)

Uses of Message in io.smallrye.reactive.messaging.kafka.i18n

Methods in io.smallrye.reactive.messaging.kafka.i18n with parameters of type Message

Modifier and Type	Method and Description
void	KafkaLogging.nackingMessage(Message message, String topic, Throwable t)
void	KafkaLogging_$logger.nackingMessage(Message message, String topic, Throwable t)
void	KafkaLogging.sendingMessageToTopic(Message message, String topic)
void	KafkaLogging_$logger.sendingMessageToTopic(Message message, String topic)
void	KafkaLogging.successfullyToTopic(Message message, String topic)
void	KafkaLogging_$logger.successfullyToTopic(Message message, String topic)

Uses of Message in io.smallrye.reactive.messaging.kafka.impl

Methods in io.smallrye.reactive.messaging.kafka.impl that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	KafkaSink.getSink()

Uses of Message in io.smallrye.reactive.messaging.kafka.impl.ce

Methods in io.smallrye.reactive.messaging.kafka.impl.ce with parameters of type Message

Modifier and Type	Method and Description
static org.apache.kafka.clients.producer.ProducerRecord<?,?>	KafkaCloudEventHelper.createBinaryRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)
static org.apache.kafka.clients.producer.ProducerRecord<?,?>	KafkaCloudEventHelper.createStructuredRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)

Uses of Message in io.smallrye.reactive.messaging.metrics

Methods in io.smallrye.reactive.messaging.metrics that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	MetricDecorator.decorate(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher, String channelName)

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

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	MetricDecorator.decorate(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher, String channelName)

Uses of Message in io.smallrye.reactive.messaging.mqtt

Subinterfaces of Message in io.smallrye.reactive.messaging.mqtt

Modifier and Type	Interface and Description
interface	MqttMessage<T>

Classes in io.smallrye.reactive.messaging.mqtt that implement Message

Modifier and Type	Class and Description
class	ReceivingMqttMessage
class	SendingMqttMessage<T>

Methods in io.smallrye.reactive.messaging.mqtt that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	MqttConnector.getPublisherBuilder(org.eclipse.microprofile.config.Config config)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	MqttSink.getSink()
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	MqttConnector.getSubscriberBuilder(org.eclipse.microprofile.config.Config config)

Uses of Message in io.smallrye.reactive.messaging.rabbitmq

Classes in io.smallrye.reactive.messaging.rabbitmq that implement Message

Modifier and Type	Class and Description
class	IncomingRabbitMQMessage<T> An implementation of Message suitable for incoming RabbitMQ messages.

Methods in io.smallrye.reactive.messaging.rabbitmq that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	RabbitMQConnector.getPublisherBuilder(org.eclipse.microprofile.config.Config config) Creates a channel for the given configuration.
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	RabbitMQConnector.getSubscriberBuilder(org.eclipse.microprofile.config.Config config) Creates a channel for the given configuration.

Methods in io.smallrye.reactive.messaging.rabbitmq with parameters of type Message

Modifier and Type	Method and Description
static RabbitMQMessageConverter.OutgoingRabbitMQMessage	RabbitMQMessageConverter.convert(Message<?> message, String exchange, String defaultRoutingKey, Optional<Long> defaultTtl, boolean isTracingEnabled, List<String> attributeHeaders) Converts the supplied Message to an RabbitMQMessageConverter.OutgoingRabbitMQMessage.
void	RabbitMQMessageSender.onNext(Message<?> message) Data notification sent by the Publisher in response to requests to Subscription.request(long).

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

Modifier and Type	Method and Description
void	RabbitMQMessageSender.subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber) Request Publisher to start streaming data.

Uses of Message in io.smallrye.reactive.messaging.rabbitmq.tracing

Methods in io.smallrye.reactive.messaging.rabbitmq.tracing that return Message

Modifier and Type	Method and Description
static <T> Message<T>	TracingUtils.addIncomingTrace(IncomingRabbitMQMessage<T> msg, String queue, List<String> attributeHeaders) Creates a span based on any tracing metadata in the incoming message.

Methods in io.smallrye.reactive.messaging.rabbitmq.tracing with parameters of type Message

Modifier and Type	Method and Description
static void	TracingUtils.createOutgoingTrace(Message<?> message, Map<String,Object> headers, String exchange, String routingKey, List<String> attributeHeaders) Creates a new outgoing message span message, and ensures span metadata is added to the message headers.

Uses of Message in org.eclipse.microprofile.reactive.messaging

Methods in org.eclipse.microprofile.reactive.messaging with type parameters of type Message

Modifier and Type	Method and Description
<M extends Message<? extends T>> void	Emitter.send(M msg) Sends a message to the channel.

Methods in org.eclipse.microprofile.reactive.messaging that return Message

Modifier and Type	Method and Description
default Message<T>	Message.addMetadata(Object metadata) Creates a new instance of Message with the current metadata, plus the given one.
static <T> Message<T>	Message.of(T payload) Create a message with the given payload.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata) Create a message with the given payload and metadata.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata, Supplier<CompletionStage<Void>> ack) Create a message with the given payload, metadata and ack function.
static <T> Message<T>	Message.of(T payload, Iterable<Object> metadata, Supplier<CompletionStage<Void>> ack, Function<Throwable,CompletionStage<Void>> nack) Create a message with the given payload, metadata and ack and nack functions.
static <T> Message<T>	Message.of(T payload, Metadata metadata) Create a message with the given payload and metadata.
static <T> Message<T>	Message.of(T payload, Metadata metadata, Supplier<CompletionStage<Void>> ack) Create a message with the given payload, metadata and ack function.
static <T> Message<T>	Message.of(T payload, Metadata metadata, Supplier<CompletionStage<Void>> ack, Function<Throwable,CompletionStage<Void>> nack) Create a message with the given payload, metadata and ack and nack functions.
static <T> Message<T>	Message.of(T payload, Supplier<CompletionStage<Void>> ack) Create a message with the given payload and ack function.
static <T> Message<T>	Message.of(T payload, Supplier<CompletionStage<Void>> ack, Function<Throwable,CompletionStage<Void>> nack) Create a message with the given payload, ack and nack functions.
default Message<T>	Message.withAck(Supplier<CompletionStage<Void>> supplier) Creates a new instance of Message with the given acknowledgement supplier.
default Message<T>	Message.withMetadata(Iterable<Object> metadata) Creates a new instance of Message with the specified metadata.
default Message<T>	Message.withMetadata(Metadata metadata) Creates a new instance of Message with the specified metadata.
default Message<T>	Message.withNack(Function<Throwable,CompletionStage<Void>> nack) Creates a new instance of Message with the given negative-acknowledgement function.
default <P> Message<P>	Message.withPayload(P payload) Creates a new instance of Message with the specified payload.

Uses of Message in org.eclipse.microprofile.reactive.messaging.spi

Methods in org.eclipse.microprofile.reactive.messaging.spi that return types with arguments of type Message

Modifier and Type	Method and Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	IncomingConnectorFactory.getPublisherBuilder(org.eclipse.microprofile.config.Config config) Creates a channel for the given configuration.
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	OutgoingConnectorFactory.getSubscriberBuilder(org.eclipse.microprofile.config.Config config) Creates a channel for the given configuration.

Uses of Message in outbound

Methods in outbound that return types with arguments of type Message

Modifier and Type	Method and Description
io.smallrye.mutiny.Multi<Message<Double>>	KafkaPriceMessageProducer.generate()