Как потреблять и публиковать сообщения с Micronaut и RabbitMQ?

Question

Micronaut 1.0.0 только что выпущен (2018-10-25), и в его документации для RabbitMQ , похоже, не говорится, как на самом деле потреблять или публиковать сообщения,Это просто говорит о том, что вы можете создать проект поддержки RabbitMQ, используя:

mn create-app my-app --features rabbitmq

Но как только это будет сделано, генерируется только класс Application:

import io.micronaut.runtime.Micronaut;

public class Application {

    public static void main(String[] args) {
        Micronaut.run(Application.class);
    }
}

и некоторые yaml конфигурации:

---
micronaut:
    application:
        name: my-app

---
rabbitmq:
    uri: amqp://user:pass@host:10000/vhost
    requestedFrameMax: 10
    requestedChannelMax: 10
    connectionTimeout: 5000

Но как я могу фактически начать потреблять и публиковать сообщения с RabbitMQ, используя Micronaut?

Answer 1

В настоящее время поддержка RabbitMQ очень минимальна.Вам предоставляется возможность настроить ConnectionFactory со средой микронавигации.

"Будет предоставлен bean-компонент фабрики соединений RabbitMQ на основе значений конфигурации, указанных в конфигурационном ключе rabbitmq. Все методы установки в ConnectionFactory доступны для настройки."

В этом случае доиспользовать фабрику соединений согласно документации rabbitmq https://www.rabbitmq.com/api-guide.html

Лучшая поддержка RabbitMQ (аналогично Kafka) является высоким приоритетом для Micronaut 1.1.0.