rabbitmq-java-client
rabbitmq-java-client copied to clipboard
rabbitmq
RabbitMQ Java client
Sometimes the message body can be just a subset of a byte array and the only way now to send this subset is to copy it into another array and...
This is based on 5.5.0. When implementing a recovery listener, I noticed that there is no `RecoveryCallback` counterpart for a `RecoveryListener`, to support lambda style of registering a callback. For...
Hi all, I would like to propose to use `ByteBuffer` for message bodies. Now, the API accepts a plain `byte[]`, which forces intermediate copies of buffers if we are already...
It could be useful to be able to call `Connection/Channel#close` several times safely, or to have a flag to know closing is in-progress. See https://github.com/reactor/reactor-rabbitmq/commit/053b2f0e0646b37d64216d55656534759559f055. This would be just a...
The `com.rabbitmq.client.impl.AMQContentHeader` has the following toString implementation ``` @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("#contentHeader"); this.appendPropertyDebugStringTo(sb); return sb.toString(); } ``` It generates strings like this ```...
Hello, We are using this version com.rabbitmq amqp-client 5.15.0 But 3.16.0 hasn't changed in the following regards. We are facing the issue that we need a unique identifier that should...
### Describe the bug when running a simple spring boot 3 with spring-amqp app with the debug-flag `-Djdk.tracePinnedThreads=full` Thread-Pinning occurs. ``` Thread[#60,ForkJoinPool-1-worker-9,5,CarrierThreads] java.base/java.lang.VirtualThread$VThreadContinuation.onPinned(Unknown Source) java.base/jdk.internal.vm.Continuation.onPinned0(Unknown Source) java.base/java.lang.VirtualThread.park(Unknown Source) java.base/java.lang.System$2.parkVirtualThread(Unknown Source)...
The ConnectionFactory class has dozens of parameters. It can be overwhelming to configure, especially for tricky topics like TLS where the parameters are among the other dozens, without clear way...