From 0e75e5e85408baae7524c3c0b182bcf2cb102266 Mon Sep 17 00:00:00 2001 From: Clement Escoffier Date: Sat, 23 Feb 2019 09:39:24 +0100 Subject: [PATCH] Move the acknowledgment class The Acknowledgement class is now part of the spec. --- doc/acknowledgment.adoc | 2 +- .../reactive/messaging/snippets/Ack.java | 2 +- .../messaging/amqp/ConsumptionBean.java | 2 +- .../messaging/amqp/ProducingBean.java | 2 +- .../messaging/kafka/ConsumptionBean.java | 2 +- .../messaging/kafka/ProducingBean.java | 2 +- .../kafka/ProducingKafkaMessageBean.java | 2 +- .../messaging/mqtt/ProducingBean.java | 2 +- .../reactive/messaging/AbstractMediator.java | 2 +- .../messaging/MediatorConfiguration.java | 2 +- .../messaging/annotations/Acknowledgment.java | 88 ------------------- .../ack/BeanWithMessageProcessors.java | 2 +- .../ack/BeanWithPayloadProcessors.java | 2 +- ...eanWithProcessorsManipulatingMessages.java | 2 +- ...eanWithProcessorsManipulatingPayloads.java | 2 +- ...WithProcessorsProducingMessageStreams.java | 2 +- ...WithProcessorsProducingPayloadStreams.java | 2 +- .../ack/BeanWithStreamTransformers.java | 2 +- ...anWithMethodsReturningCompletionStage.java | 2 +- ...erBeanWithMethodsReturningSubscribers.java | 2 +- ...ubscriberBeanWithMethodsReturningVoid.java | 2 +- .../messaging/eventbus/ProducingBean.java | 2 +- 22 files changed, 21 insertions(+), 109 deletions(-) delete mode 100644 smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/annotations/Acknowledgment.java diff --git a/doc/acknowledgment.adoc b/doc/acknowledgment.adoc index f9d748f4..aa9d045f 100644 --- a/doc/acknowledgment.adoc +++ b/doc/acknowledgment.adoc @@ -1,7 +1,7 @@ == Acknowledgement Messages may require acknowledgment to inform the transport layer that the message has been processed. Methods -annotated with `@Incoming` and also be annotated with `io.smallrye.reactive.messaging.annotations.Acknowledgment` to +annotated with `@Incoming` and also be annotated with `org.eclipse.microprofile.reactive.messaging.Acknowledgment` to configure the acknowledgement policies. Four policies are supported: diff --git a/examples/snippets/src/main/java/io/smallrye/reactive/messaging/snippets/Ack.java b/examples/snippets/src/main/java/io/smallrye/reactive/messaging/snippets/Ack.java index fc8d501c..fef32f3b 100644 --- a/examples/snippets/src/main/java/io/smallrye/reactive/messaging/snippets/Ack.java +++ b/examples/snippets/src/main/java/io/smallrye/reactive/messaging/snippets/Ack.java @@ -1,6 +1,6 @@ package io.smallrye.reactive.messaging.snippets; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ConsumptionBean.java b/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ConsumptionBean.java index d3c358c1..dc97f929 100644 --- a/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ConsumptionBean.java +++ b/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ConsumptionBean.java @@ -1,6 +1,6 @@ package io.smallrye.reactive.messaging.amqp; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.config.Config; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; diff --git a/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ProducingBean.java b/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ProducingBean.java index 0fa3cd77..653b40f2 100644 --- a/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ProducingBean.java +++ b/smallrye-reactive-messaging-amqp/src/test/java/io/smallrye/reactive/messaging/amqp/ProducingBean.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.amqp; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.config.Config; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; diff --git a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ConsumptionBean.java b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ConsumptionBean.java index 9cc33bd2..b2015594 100644 --- a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ConsumptionBean.java +++ b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ConsumptionBean.java @@ -1,6 +1,6 @@ package io.smallrye.reactive.messaging.kafka; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.apache.kafka.common.serialization.IntegerDeserializer; import org.apache.kafka.common.serialization.IntegerSerializer; import org.apache.kafka.common.serialization.StringDeserializer; diff --git a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingBean.java b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingBean.java index ce931288..3e73e332 100644 --- a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingBean.java +++ b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingBean.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.kafka; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.apache.kafka.common.serialization.IntegerDeserializer; import org.apache.kafka.common.serialization.IntegerSerializer; import org.apache.kafka.common.serialization.StringDeserializer; diff --git a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingKafkaMessageBean.java b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingKafkaMessageBean.java index d070da7d..f17a8e3d 100644 --- a/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingKafkaMessageBean.java +++ b/smallrye-reactive-messaging-kafka/src/test/java/io/smallrye/reactive/messaging/kafka/ProducingKafkaMessageBean.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.kafka; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.apache.kafka.common.serialization.IntegerDeserializer; import org.apache.kafka.common.serialization.IntegerSerializer; import org.apache.kafka.common.serialization.StringDeserializer; diff --git a/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/ProducingBean.java b/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/ProducingBean.java index e16f77a3..7ff5a2c6 100644 --- a/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/ProducingBean.java +++ b/smallrye-reactive-messaging-mqtt/src/test/java/io/smallrye/reactive/messaging/mqtt/ProducingBean.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.mqtt; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.config.Config; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; diff --git a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/AbstractMediator.java b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/AbstractMediator.java index 6f291abf..09843deb 100644 --- a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/AbstractMediator.java +++ b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/AbstractMediator.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Message; import org.reactivestreams.Publisher; import org.reactivestreams.Subscriber; diff --git a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/MediatorConfiguration.java b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/MediatorConfiguration.java index 1ecbc02d..5877c524 100644 --- a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/MediatorConfiguration.java +++ b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/MediatorConfiguration.java @@ -1,6 +1,6 @@ package io.smallrye.reactive.messaging; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import io.smallrye.reactive.messaging.annotations.Broadcast; import io.smallrye.reactive.messaging.annotations.Merge; import org.apache.commons.lang3.ClassUtils; diff --git a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/annotations/Acknowledgment.java b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/annotations/Acknowledgment.java deleted file mode 100644 index 9370f455..00000000 --- a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/annotations/Acknowledgment.java +++ /dev/null @@ -1,88 +0,0 @@ -package io.smallrye.reactive.messaging.annotations; - -import org.eclipse.microprofile.reactive.messaging.Message; - -import java.lang.annotation.Retention; -import java.lang.annotation.RetentionPolicy; - -/** - * Configure the acknowledgement policy for the given {@code @Incoming}. - * - * The set of supported acknowledgment policy depends on the method signature. The given list indicates the supported - * policies for each type of signature: - * - * - * - */ -@Retention(RetentionPolicy.RUNTIME) -public @interface Acknowledgment { - - enum Strategy { - /** - * No acknowledgment performed. - */ - NONE, - - /** - * Acknowledgment managed by the user code. No automatic acknowledgment is performed. This strategy is only - * supported by methods consuming {@link Message} instances. - */ - MANUAL, - - /** - * Acknowledgment performed automatically before the processing of the message by the user code. - */ - PRE_PROCESSING, - - /** - * Acknowledgment performed automatically after the user processing of the message. - * - * Notice that this mode is not supported for all signatures. check the list above. - * When supported it's the default policy. - * - */ - POST_PROCESSING - } - - /** - * @return the acknowledgement policy. - */ - Strategy value(); - -} diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithMessageProcessors.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithMessageProcessors.java index 7c9c5426..eed9d617 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithMessageProcessors.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithMessageProcessors.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.ack; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithPayloadProcessors.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithPayloadProcessors.java index 007847b4..54f66461 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithPayloadProcessors.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithPayloadProcessors.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.ack; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingMessages.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingMessages.java index 309d2064..a42eda69 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingMessages.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingMessages.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.ack; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import io.smallrye.reactive.messaging.annotations.Merge; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingPayloads.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingPayloads.java index d6af22e7..6b05d5d8 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingPayloads.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsManipulatingPayloads.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.ack; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingMessageStreams.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingMessageStreams.java index b5fcb41a..f98b06a2 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingMessageStreams.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingMessageStreams.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.ack; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingPayloadStreams.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingPayloadStreams.java index 0ba8a3f8..b4713c55 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingPayloadStreams.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithProcessorsProducingPayloadStreams.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.ack; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithStreamTransformers.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithStreamTransformers.java index 226849d1..ebba5a4a 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithStreamTransformers.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/BeanWithStreamTransformers.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.ack; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningCompletionStage.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningCompletionStage.java index 4d292af6..6b023ef6 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningCompletionStage.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningCompletionStage.java @@ -1,6 +1,6 @@ package io.smallrye.reactive.messaging.ack; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningSubscribers.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningSubscribers.java index b5d8f542..31aecb08 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningSubscribers.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningSubscribers.java @@ -1,6 +1,6 @@ package io.smallrye.reactive.messaging.ack; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningVoid.java b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningVoid.java index 8c71ba5f..81339a55 100644 --- a/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningVoid.java +++ b/smallrye-reactive-messaging-provider/src/test/java/io/smallrye/reactive/messaging/ack/SubscriberBeanWithMethodsReturningVoid.java @@ -1,6 +1,6 @@ package io.smallrye.reactive.messaging.ack; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import org.eclipse.microprofile.reactive.messaging.Incoming; import org.eclipse.microprofile.reactive.messaging.Message; import org.eclipse.microprofile.reactive.messaging.Outgoing; diff --git a/smallrye-reactive-messaging-vertx-eventbus/src/test/java/io/smallrye/reactive/messaging/eventbus/ProducingBean.java b/smallrye-reactive-messaging-vertx-eventbus/src/test/java/io/smallrye/reactive/messaging/eventbus/ProducingBean.java index d9f3ff11..b47e6666 100644 --- a/smallrye-reactive-messaging-vertx-eventbus/src/test/java/io/smallrye/reactive/messaging/eventbus/ProducingBean.java +++ b/smallrye-reactive-messaging-vertx-eventbus/src/test/java/io/smallrye/reactive/messaging/eventbus/ProducingBean.java @@ -1,7 +1,7 @@ package io.smallrye.reactive.messaging.eventbus; import io.reactivex.Flowable; -import io.smallrye.reactive.messaging.annotations.Acknowledgment; +import org.eclipse.microprofile.reactive.messaging.Acknowledgment; import io.vertx.reactivex.core.Vertx; import org.eclipse.microprofile.config.Config; import org.eclipse.microprofile.reactive.messaging.Incoming;