Uses of Interface
org.eclipse.microprofile.reactive.messaging.Message
-
-
Uses of Message in inbound
Methods in inbound with parameters of type Message Modifier and Type Method 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 Description <M extends Message<? extends T>>
voidMutinyEmitter. send(M msg)
Sends a message to the channel.Methods in io.smallrye.reactive.messaging that return Message Modifier and Type Method Description Message<?>
MessageConverter. convert(Message<?> in, Type target)
Converts the given messagein
into aMessage<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 Description io.smallrye.mutiny.Multi<? extends Message<?>>
AbstractMediator. convert(io.smallrye.mutiny.Multi<? extends Message<?>> upstream)
io.smallrye.mutiny.Multi<? extends Message<?>>
AbstractMediator. decorate(io.smallrye.mutiny.Multi<? extends Message<?>> input)
io.smallrye.mutiny.Multi<? extends Message<?>>
PublisherDecorator. decorate(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, String channelName)
Decorate a Multiprotected CompletionStage<Message<?>>
AbstractMediator. getAckOrCompletion(Message<?> message)
org.reactivestreams.Subscriber<Message<?>>
AbstractMediator. getComputedSubscriber()
org.reactivestreams.Subscriber<Message<?>>
SubscriberMediator. getComputedSubscriber()
List<org.reactivestreams.Publisher<? extends Message<?>>>
ChannelRegistry. getPublishers(String name)
io.smallrye.mutiny.Multi<? extends Message<?>>
AbstractMediator. getStream()
io.smallrye.mutiny.Multi<? extends Message<?>>
ProcessorMediator. getStream()
io.smallrye.mutiny.Multi<? extends Message<?>>
PublisherMediator. getStream()
io.smallrye.mutiny.Multi<? extends Message<?>>
StreamTransformerMediator. getStream()
List<org.reactivestreams.Subscriber<? extends Message<?>>>
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()
org.reactivestreams.Publisher<? extends Message<?>>
ChannelRegistry. register(String name, org.reactivestreams.Publisher<? extends Message<?>> stream, boolean broadcast)
org.reactivestreams.Subscriber<? extends Message<?>>
ChannelRegistry. register(String name, org.reactivestreams.Subscriber<? extends Message<?>> subscriber, boolean merge)
Methods in io.smallrye.reactive.messaging with parameters of type Message Modifier and Type Method Description boolean
MessageConverter. canConvert(Message<?> in, Type target)
Checks whether this instance of converter can convert the given messagein
into aMessage<T>
withT
being the type represented bytarget
.boolean
MessageConverter.IdentityConverter. canConvert(Message<?> in, Type target)
Message<?>
MessageConverter. convert(Message<?> in, Type target)
Converts the given messagein
into aMessage<T>
.Message<?>
MessageConverter.IdentityConverter. convert(Message<?> in, Type target)
static Optional<TracingMetadata>
TracingMetadata. fromMessage(Message<?> 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 Description void
AbstractMediator. connectToUpstream(io.smallrye.mutiny.Multi<? extends Message<?>> publisher)
void
ProcessorMediator. connectToUpstream(io.smallrye.mutiny.Multi<? extends Message<?>> publisher)
void
StreamTransformerMediator. connectToUpstream(io.smallrye.mutiny.Multi<? extends Message<?>> publisher)
void
SubscriberMediator. connectToUpstream(io.smallrye.mutiny.Multi<? extends Message<?>> publisher)
io.smallrye.mutiny.Multi<? extends Message<?>>
AbstractMediator. convert(io.smallrye.mutiny.Multi<? extends Message<?>> upstream)
io.smallrye.mutiny.Multi<? extends Message<?>>
AbstractMediator. decorate(io.smallrye.mutiny.Multi<? extends Message<?>> input)
io.smallrye.mutiny.Multi<? extends Message<?>>
PublisherDecorator. decorate(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, String channelName)
Decorate a Multiorg.reactivestreams.Publisher<? extends Message<?>>
ChannelRegistry. register(String name, org.reactivestreams.Publisher<? extends Message<?>> stream, boolean broadcast)
org.reactivestreams.Subscriber<? extends Message<?>>
ChannelRegistry. register(String name, org.reactivestreams.Subscriber<? extends Message<?>> 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 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 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 Description void
AmqpCreditBasedSender. onNext(Message<?> message)
Method parameters in io.smallrye.reactive.messaging.amqp with type arguments of type Message Modifier and Type Method 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 Description class
CamelMessage<T>
Methods in io.smallrye.reactive.messaging.camel that return types with arguments of type Message Modifier and Type Method 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.connector
Methods in io.smallrye.reactive.messaging.connector that return types with arguments of type Message Modifier and Type Method Description org.reactivestreams.Publisher<? extends Message<?>>
InboundConnector. getPublisher(org.eclipse.microprofile.config.Config config)
Creates a channel for the given configuration.org.reactivestreams.Subscriber<? extends Message<?>>
OutboundConnector. getSubscriber(org.eclipse.microprofile.config.Config config)
Creates a channel for the given configuration. -
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 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 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 Description <M extends Message<? extends T>>
voidEmitterImpl. send(M msg)
<M extends Message<? extends T>>
voidMutinyEmitterImpl. send(M msg)
Methods in io.smallrye.reactive.messaging.extension that return types with arguments of type Message Modifier and Type Method Description org.reactivestreams.Publisher<Message<? extends T>>
AbstractEmitter. getPublisher()
protected io.smallrye.mutiny.subscription.MultiEmitter<? super Message<? extends T>>
AbstractEmitter. verify()
Methods in io.smallrye.reactive.messaging.extension with parameters of type Message Modifier and Type Method Description protected void
AbstractEmitter. emit(Message<? extends T> message)
-
Uses of Message in io.smallrye.reactive.messaging.helpers
Fields in io.smallrye.reactive.messaging.helpers with type parameters of type Message Modifier and Type Field Description static org.reactivestreams.Subscriber<Message<?>>
IgnoringSubscriber. INSTANCE
Methods in io.smallrye.reactive.messaging.helpers that return types with arguments of type Message Modifier and Type Method Description static io.smallrye.mutiny.Multi<? extends Message<?>>
BroadcastHelper. broadcastPublisher(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, int numberOfSubscriberBeforeConnecting)
Wraps an existingPublisher
for broadcasting.static io.smallrye.mutiny.Multi<? extends Message<?>>
MultiUtils. handlePreProcessingAcknowledgement(io.smallrye.mutiny.Multi<? extends Message<?>> multi, MediatorConfiguration configuration)
Methods in io.smallrye.reactive.messaging.helpers with parameters of type Message Modifier and Type Method Description void
IgnoringSubscriber. onNext(Message<?> message)
Method parameters in io.smallrye.reactive.messaging.helpers with type arguments of type Message Modifier and Type Method Description static io.smallrye.mutiny.Multi<? extends Message<?>>
BroadcastHelper. broadcastPublisher(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, int numberOfSubscriberBeforeConnecting)
Wraps an existingPublisher
for broadcasting.static io.smallrye.mutiny.Multi<? extends Message<?>>
MultiUtils. handlePreProcessingAcknowledgement(io.smallrye.mutiny.Multi<? extends Message<?>> multi, MediatorConfiguration configuration)
-
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 Description List<org.reactivestreams.Publisher<? extends Message<?>>>
InternalChannelRegistry. getPublishers(String name)
List<org.reactivestreams.Subscriber<? extends Message<?>>>
InternalChannelRegistry. getSubscribers(String name)
org.reactivestreams.Publisher<? extends Message<?>>
InternalChannelRegistry. register(String name, org.reactivestreams.Publisher<? extends Message<?>> stream, boolean broadcast)
org.reactivestreams.Subscriber<? extends Message<?>>
InternalChannelRegistry. register(String name, org.reactivestreams.Subscriber<? extends Message<?>> subscriber, boolean merge)
Method parameters in io.smallrye.reactive.messaging.impl with type arguments of type Message Modifier and Type Method Description org.reactivestreams.Publisher<? extends Message<?>>
InternalChannelRegistry. register(String name, org.reactivestreams.Publisher<? extends Message<?>> stream, boolean broadcast)
org.reactivestreams.Subscriber<? extends Message<?>>
InternalChannelRegistry. register(String name, org.reactivestreams.Subscriber<? extends Message<?>> 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 Description class
IncomingJmsMessage<T>
Methods in io.smallrye.reactive.messaging.jms that return types with arguments of type Message Modifier and Type Method 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 Description interface
KafkaMessage<K,T>
Deprecated.Useinstead
interface
KafkaRecord<K,T>
interface
KafkaRecordBatch<K,T>
Represents a batch of Kafka records received by polling theKafkaConsumer
This type extends theMessage<List<T>>
whereT
is the type of records' payloads.Classes in io.smallrye.reactive.messaging.kafka that implement Message Modifier and Type Class Description class
IncomingKafkaRecord<K,T>
class
IncomingKafkaRecordBatch<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 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 Description static <K,T>
OutgoingKafkaRecord<K,T>KafkaRecord. from(Message<T> message)
static <K,T>
OutgoingKafkaRecord<K,T>OutgoingKafkaRecord. 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 Description static <T,K>
Message<T>KafkaMetadataUtil. writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata)
WriteOutgoingKafkaRecordMetadata
to aMessage
.Methods in io.smallrye.reactive.messaging.kafka.api with parameters of type Message Modifier and Type Method Description static Optional<IncomingKafkaRecordMetadata>
KafkaMetadataUtil. readIncomingKafkaMetadata(Message<?> msg)
ReadIncomingKafkaRecordMetadata
from aMessage
.static <T,K>
Message<T>KafkaMetadataUtil. writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata)
WriteOutgoingKafkaRecordMetadata
to aMessage
. -
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 Description Message<?>
ConsumerRecordConverter. convert(Message<?> in, Type target)
Message<?>
ConsumerRecordsConverter. 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 Description boolean
ConsumerRecordConverter. canConvert(Message<?> in, Type target)
boolean
ConsumerRecordsConverter. canConvert(Message<?> in, Type target)
boolean
RecordConverter. canConvert(Message<?> in, Type target)
Message<?>
ConsumerRecordConverter. convert(Message<?> in, Type target)
Message<?>
ConsumerRecordsConverter. 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 Description void
KafkaLogging_$logger. nackingMessage(Message<?> message, String topic, Throwable t)
void
KafkaLogging. nackingMessage(Message<?> message, String topic, Throwable t)
void
KafkaLogging_$logger. sendingMessageToTopic(Message<?> message, String topic)
void
KafkaLogging. sendingMessageToTopic(Message<?> message, String topic)
void
KafkaLogging_$logger. successfullyToTopic(Message<?> message, String topic)
void
KafkaLogging. 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 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 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 Description io.smallrye.mutiny.Multi<? extends Message<?>>
MetricDecorator. decorate(io.smallrye.mutiny.Multi<? extends Message<?>> publisher, String channelName)
Method parameters in io.smallrye.reactive.messaging.metrics with type arguments of type Message Modifier and Type Method Description io.smallrye.mutiny.Multi<? extends Message<?>>
MetricDecorator. decorate(io.smallrye.mutiny.Multi<? 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 Description interface
MqttMessage<T>
Classes in io.smallrye.reactive.messaging.mqtt that implement Message Modifier and Type Class 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 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 Description class
IncomingRabbitMQMessage<T>
An implementation ofMessage
suitable for incoming RabbitMQ messages.Methods in io.smallrye.reactive.messaging.rabbitmq that return types with arguments of type Message Modifier and Type Method 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 Description static RabbitMQMessageConverter.OutgoingRabbitMQMessage
RabbitMQMessageConverter. convert(Message<?> message, String exchange, String defaultRoutingKey, Optional<Long> defaultTtl, boolean isTracingEnabled, List<String> attributeHeaders)
Converts the suppliedMessage
to anRabbitMQMessageConverter.OutgoingRabbitMQMessage
.void
RabbitMQMessageSender. onNext(Message<?> message)
Data notification sent by thePublisher
in response to requests toSubscription.request(long)
.Method parameters in io.smallrye.reactive.messaging.rabbitmq with type arguments of type Message Modifier and Type Method Description void
RabbitMQMessageSender. subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)
RequestPublisher
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 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 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 Description <M extends Message<? extends T>>
voidEmitter. send(M msg)
Sends a message to the channel.Methods in org.eclipse.microprofile.reactive.messaging that return Message Modifier and Type Method Description default Message<T>
Message. addMetadata(Object metadata)
Creates a new instance ofMessage
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, 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.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.default Message<T>
Message. withAck(Supplier<CompletionStage<Void>> supplier)
Creates a new instance ofMessage
with the given acknowledgement supplier.default Message<T>
Message. withMetadata(Iterable<Object> metadata)
Creates a new instance ofMessage
with the specified metadata.default Message<T>
Message. withMetadata(Metadata metadata)
Creates a new instance ofMessage
with the specified metadata.default Message<T>
Message. withNack(Function<Throwable,CompletionStage<Void>> nack)
Creates a new instance ofMessage
with the given negative-acknowledgement function.default <P> Message<P>
Message. withPayload(P payload)
Creates a new instance ofMessage
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 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 Description io.smallrye.mutiny.Multi<Message<Double>>
KafkaPriceMessageProducer. generate()
-