Resolving IllegalStateException: Message body is too large in Quarkus RabbitMQ

[kiratkumar47]

Hi everyone! 👋 I'm hitting a message size limit issue while consuming from RabbitMQ.

Error: java.lang.IllegalStateException: Message body is too large (104857600), maximum configured size is 67108864.

Environment: Quarkus 3.15.x (or 3.2.x), quarkus-messaging-rabbitmq extension.

Context: The message is ~100MB, but the default limit is 64MB.

I’ve tried a few approaches to adjust the maxInboundMessageBodySize, but I haven't found the right way to apply this configuration within the Quarkus/SmallRye reactive messaging framework. Has anyone successfully tuned this limit via application.properties or a custom ConnectionFactory producer?

[quarkus-bot[bot]]

/cc @cescoffier (reactive-messaging), @ozangunalp (reactive-messaging)

[cescoffier]

Did you try the RabbitMQ client customization?

@Produces
@Identifier("my-named-options")
public RabbitMQOptions getNamedOptions() {
  PemKeyCertOptions keycert = new PemKeyCertOptions()
        .addCertPath("./tls/tls.crt")
        .addKeyPath("./tls/tls.key");
  PemTrustOptions trust = new PemTrustOptions().addCertPath("./tlc/ca.crt");
  // You can use the produced options to configure the TLS connection
  return new RabbitMQOptions()
        .setSsl(true)
        .setPemKeyCertOptions(keycert)
        .setPemTrustOptions(trust)
        .setUser("user1")
        .setPassword("password1")
        .setHost("localhost")
        .setPort(5672)
        .setVirtualHost("vhost1")
        .setConnectionTimeout(6000) // in milliseconds
        .setRequestedHeartbeat(60) // in seconds
        .setHandshakeTimeout(6000) // in milliseconds
        .setRequestedChannelMax(5)
        .setNetworkRecoveryInterval(500) // in milliseconds
        .setAutomaticRecoveryEnabled(true);
}

[kiratkumar47]

Thank you for the response @cescoffier ,
I don't find any method in RabbitMQOptions that increases the queue size. Is there another way to increase the size while using this approach.