Quarkus с ActiveMQ?

Question

После того, как попробовал Quarkus с Kafka, мне стало интересно, как использовать его с ActiveMQ.Я не смог найти никакой документации.Quarkus.io упоминает о поддержке протокола amqp.

Кто-нибудь знает, как этого добиться?

Answer 1

В дополнение к ответу, предоставленному @John Clingan (спасибо!) О прямом использовании VertX, вы также можете использовать microprofile-реагирующий-обмен сообщениями:

1. Текущая версия (0.0.7) расширения smallrye amqp не работает с Quarkus (нет пустого конструктора для CDI). Исправление уже есть в основной ветке.

git clone https://github.com/smallrye/smallrye-reactive-messaging.git
cd smallrye-reactive-messaging
mvn install

2. Добавьте недавно построенный артефакт к вашему помпоненту

<dependency>
   <groupId>io.smallrye.reactive</groupId>
   <artifactId>smallrye-reactive-messaging-amqp</artifactId>
   <version>0.0.8-SNAPSHOT</version>
</dependency>

3. Настройка amqp в application.properties

# amqp output
smallrye.messaging.sink.my-amqp-output.type=io.smallrye.reactive.messaging.amqp.Amqp
smallrye.messaging.sink.my-amqp-output.address=test-activemq-amqp
smallrye.messaging.sink.my-amqp-output.containerId=test-activemq-clientid
smallrye.messaging.sink.my-amqp-output.host=localhost

# amqp input
smallrye.messaging.source.my-amqp-input.type=io.smallrye.reactive.messaging.amqp.Amqp
smallrye.messaging.source.my-amqp-input.address=test-activemq-amqp
smallrye.messaging.source.my-amqp-input.containerId=test-activemq-clientid
smallrye.messaging.source.my-amqp-input.host=localhost

3. Использовать микропрофиль-реактивный-обмен сообщениями

3.1 Отправка сообщений от сервлета отдыха

@Path("/hello")
public class HelloWorldResource {

    @Inject
    @Stream("my-amqp-output")
    Emitter<String> emitter;

    @GET
    @Produces(MediaType.TEXT_PLAIN)
    public String hello() {        
        emitter.send("hello!");
        return "hello send";
    }
}

3.2 Получение сообщений

@ApplicationScoped
public class AmqpReceiver {    

    @Incoming("my-amqp-input")
    public void receive(String input) {
        //process message
    }
}

Протестировано с кварками 0.14.0 и 0.13.3.