How to configure RabbitMQ as AMQP broker in dev resource

[hantsy]

I want to configure RabbitMQ as AMQP broker in the dev resource, but tried the following config, both are not worked as expected,

quarkus.amqp.devservices.image-name=rabbitmq:3-management-alpine

or

quarkus.rabbitmq.devservices.enabled=true
quarkus.rabbitmq.devservices.image-name=rabbitmq:3-management-alpine

[ozangunalp]

It is not possible to do it OOTB as it requires enabling and configuring AMQP 1.0 plugin.

However, you can configure and run a rabbitmq image locally, exposing a port mapping for the default AMQP 1.0 port with a label quarkus-dev-service-amqp=amqp. The AMQP dev service will pick and configure your application with this service instead of creating a new one.
For example with docker compose it'll look like :

version: '3.8'

services:
  some-rabbit:
    image: rabbitmq:3.12-management-alpine
    labels:
      - quarkus-dev-service-amqp=amqp
    ports:
      - '5671'
      - '15671'
      - '5672'
      - '15672'
    volumes:
      - './enabled_plugins:/etc/rabbitmq/enabled_plugins:ro'
      - './custom_rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf'

[hantsy]

Tried, but not sure where, it did not work as expected, https://github.com/hantsy/quarkus-sandbox/tree/master/amqp-rabbitmq

[hantsy]

Got the following exception:

2023-07-29 12:46:24,831 INFO  [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2023-07-29 12:46:26,391 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$A
nnotatedConnectException: Connection refused: no further information: localhost/127.0.0.1:15672
Caused by: java.net.ConnectException: Connection refused: no further information
        at java.base/sun.nio.ch.Net.pollConnect(Native Method)
        at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:673)
        at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:973)
        at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:337)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:334)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.base/java.lang.Thread.run(Thread.java:1623)


2023-07-29 12:46:34,797 INFO  [io.sma.rea.mes.amqp] (executor-thread-1) SRMSG16212: Establishing connection with AMQP broker
2023-07-29 12:46:36,354 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.netty.channel.AbstractChannel$A
nnotatedConnectException: Connection refused: no further information: localhost/127.0.0.1:15672
Caused by: java.net.ConnectException: Connection refused: no further information
        at java.base/sun.nio.ch.Net.pollConnect(Native Method)
        at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:673)
        at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:973)
        at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:337)
        at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:334)
        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)
        at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.base/java.lang.Thread.run(Thread.java:1623)

If deleted the amqp-host and amqp-port in the application.properties, it returns back to use atermis as broker.

[ozangunalp]

You'd still need to start the docker compose manually. Did you do it?

[hantsy]

I have tried to start docker container firstly, still encountered the connection issue.

[ozangunalp]

Also you'd need to mount following files in my example to enable the AMQP 1.0 support correctly :
enabled_plugins:

[rabbitmq_amqp1_0].

custom_rabbitmq.conf:

amqp1_0.default_user  = guest
amqp1_0.default_vhost = /
amqp1_0.protocol_strict_mode = false

[ozangunalp]

I pushed my example here: https://github.com/ozangunalp/code-with-quarkus-amqp-1.0-rabbitmq

[hantsy]

The difference I setup the username/password, and I do not contain a rabbitmq config file. The config in the custom_rabbitmq.conf is a must for Quarkus Dev Resource?

[hantsy]

I have tried to use a TestResource in the testing codes, it works.
https://github.com/hantsy/quarkus-sandbox/blob/master/amqp-rabbitmq/src/test/java/com/example/RabbitMQTestResource.java

[ozangunalp]

This has nothing to do with Quarkus. Just configuring rabbitmq for accepting AMQP 1.0 protocol

[pranith-shabodi]

I have added configuration related to rabbitmq.
quarkus.rabbitmq.username=guest
quarkus.rabbitmq.password=guest
quarkus.rabbitmq.host=127.0.0.1
quarkus.rabbitmq.port=5672

Reactive Messaging properties

mp.messaging.incoming.AEP-alarm-queue.connector=smallrye-amqp
mp.messaging.incoming.AEP-alarm-queue.host=${quarkus.rabbitmq.host}
mp.messaging.incoming.AEP-alarm-queue.port=${quarkus.rabbitmq.port}
mp.messaging.incoming.AEP-alarm-queue.username=${quarkus.rabbitmq.username}
mp.messaging.incoming.AEP-alarm-queue.password=${quarkus.rabbitmq.password}
mp.messaging.incoming.AEP-alarm-queue.containerId=my-rabbitmq-container
mp.messaging.incoming.AEP-alarm-queue.auto-create-container=true
mp.messaging.incoming.AEP-alarm-queue.durable=false
mp.messaging.incoming.AEP-alarm-queue.address=my-routing-key
quarkus.rabbitmq.connection-uri=amqp://guest:guest@localhost:15672

quarkus.amqp.devservices.enabled=false
quarkus.amqp.devservices.shared=false.

[pranith-shabodi]

Hi,

I am also facing same issue.
Please help me to resolve this. @hantsy @ozangunalp

2023-08-10 09:41:24,650 INFO [io.sma.rea.mes.amqp] (Quarkus Main Thread) SRMSG16212: Establishing connection with AMQP broker
2023-08-10 09:41:24,840 ERROR [io.ver.cor.net.imp.ConnectionBase] (vert.x-eventloop-thread-0) Connection reset
2023-08-10 09:41:24,848 ERROR [io.sma.rea.mes.amqp] (vert.x-eventloop-thread-0) SRMSG16215: Unable to connect to the broker, retry will be attempted: io.vertx.core.VertxException: Disconnected
at io.vertx.proton.impl.ProtonClientImpl.lambda$null$0(ProtonClientImpl.java:81)
at io.vertx.proton.impl.ProtonConnectionImpl.fireDisconnect(ProtonConnectionImpl.java:381)
at io.vertx.proton.impl.ProtonTransport.handleSocketEnd(ProtonTransport.java:95)
at io.vertx.core.net.impl.NetSocketImpl.lambda$new$1(NetSocketImpl.java:96)
at io.vertx.core.streams.impl.InboundBuffer.handleEvent(InboundBuffer.java:255)
at io.vertx.core.streams.impl.InboundBuffer.write(InboundBuffer.java:134)
at io.vertx.core.impl.EventLoopContext.emit(EventLoopContext.java:55)
at io.vertx.core.impl.ContextBase.emit(ContextBase.java:239)
at io.vertx.core.net.impl.NetSocketImpl.handleClosed(NetSocketImpl.java:372)
at io.vertx.core.net.impl.VertxHandler.channelInactive(VertxHandler.java:143)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:301)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281)
at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901)
at io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:813)
at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:833)