Quarkus client app (smallrye-amqp) connection broken

[rafaeltuelho]

I have the following Broker CR deployed to my local K8s environment (using Kind).

apiVersion: broker.amq.io/v1beta1
kind: ActiveMQArtemis
metadata:
  name: artemis-broker
spec:
  adminUser: admin
  adminPassword: admin
  addressSettings:
    addressSetting:
      - autoCreateAddresses: true
      - autoCreateQueues: true
  console:
    expose: true
    useClientAuth: false

Broker logs

2023-02-17 13:58:26,449 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at artemis-broker-ss-0.artemis-broker-hdls-svc.activemq-artemis-operator.svc.cluster.local:61616 for protocols [CORE]
2023-02-17 13:58:26,455 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live
2023-02-17 13:58:26,455 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.28.0 [amq-broker, nodeID=246b01f5-aecb-11ed-ac0f-4ef21cc1edec] 

Broker svcs...

k get svc
NAME                          TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)              AGE
artemis-broker-hdls-svc       ClusterIP   None            <none>        8161/TCP,61616/TCP   15h
artemis-broker-ping-svc       ClusterIP   None            <none>        8888/TCP             15h
artemis-broker-wconsj-0-svc   ClusterIP   10.96.110.181   <none>        8161/TCP,8162/TCP    15h

I also deployed a simple Quarkus app that uses the smallrye-amqp connector to the same namespace.
I can confirm I can reach and connect to the Broker from the App's container:

sh-4.4$ env | grep -i amqp
AMQP_PORT=61616
AMQP_USERNAME=admin
AMQP_PASSWORD=admin
AMQP_HOST=artemis-broker-hdls-svc
sh-4.4$ curl -vvv artemis-broker-hdls-svc:61616
* Rebuilt URL to: artemis-broker-hdls-svc:61616/
*   Trying 10.244.0.12...
* TCP_NODELAY set
* Connected to artemis-broker-hdls-svc (10.244.0.12) port 61616 (#0)
> GET / HTTP/1.1
> Host: artemis-broker-hdls-svc:61616
> User-Agent: curl/7.61.1
> Accept: */*
> 

But the Quarkus app gets disconnected from the Broker...

2023-02-17 15:20:00,902 INFO  [io.sma.rea.mes.amqp] (executor-thread-0) SRMSG16212: Establishing connection with AMQP broker
2023-02-17 15:21:01,780 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:95)
        at io.vertx.core.streams.impl.InboundBuffer.handleEvent(InboundBuffer.java:239)
        at io.vertx.core.streams.impl.InboundBuffer.write(InboundBuffer.java:129)
        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:384)
        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:829)

2023-02-17 15:21:05,726 INFO  [io.sma.rea.mes.amqp] (executor-thread-0) SRMSG16212: Establishing connection with AMQP broker

on the broker logs I see this:

2023-02-17 15:18:57,669 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure to /10.244.0.14:40158 has been detected: AMQ229014: Did not receive data from /10.244.0.14:40158 within the 60000ms connection TTL. The connection will now be closed. [code=CONNECTION_TIMEDOUT]
2023-02-17 15:18:57,703 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure to /10.244.0.14:40152 has been detected: AMQ229014: Did not receive data from /10.244.0.14:40152 within the 60000ms connection TTL. The connection will now be closed. [code=CONNECTION_TIMEDOUT]
2023-02-17 15:18:57,704 WARN  [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure to /10.244.0.15:47208 has been detected: AMQ229014: Did not receive data from /10.244.0.15:47208 within the 60000ms connection TTL. The connection will now be closed. [code=CONNECTION_TIMEDOUT]

Given the broker is reachable from the Networking standpoint, Is there anything I should look at?

Thanks in advance.

[rafaeltuelho]

ok, I just learned in order to enable AMQP Protocol you need to explicitly add the acceptors in your ActiveMQArtemis CR:

apiVersion: broker.amq.io/v1beta1
kind: ActiveMQArtemis
metadata:
  name: artemis-broker-amqp
spec:
  adminUser: admin
  adminPassword: admin
  acceptors:
    - name: amqp
      expose: true
      protocols: "AMQP"
      port: 5672

[brusdev]

@rafaeltuelho thanks for your feedback