spring-amqp

spring-amqp copied to clipboard

Initial Reactive Client Support

19

- Map to/from Spring AMQP `Message` abstractions - Add support for existing payload conversion PoC based on `SampleSender` and `SampleReceiver` ```java public class SampleSender { private static final Logger LOGGER...

garyrussell

Feature: Option for @RabbitListener to Not Retry on Fatal Exception

3

Based on my understanding, and what I saw, the `@RabbitListener` will retry even if a thrown exception is fatal per `ConditionalRejectingErrorHandler.DefaultExceptionStrategy`. There are many cases where it does not make...

ryandanielspmc

Feature: dynamic queues/bindings registry

3

This is related to dynamic queues and their registration in runtime. So far, if queue is declared as a @Bean it will be detected by RabbitAdmin and declared in case...

bojanv55

Add the body object to the ClassMapper.fromClass method

3

I have written a custom `InvocableHandlerMethod`. Basically, it wraps the response of an RPC call in a in another object. With this, I can catch specific exceptions. So, the wrapper...

codemaker219

Don't Initialize Lazy Factory Beans in RabbitAdmin

1

When looking for exchanges, queues, bindings, don't use `getBeansOfType()` with eager initialization. https://stackoverflow.com/questions/54280851/how-to-make-lazy-spring-bean-not-eligible-for-creation-when-listablebeanfactory

garyrussell

Related issue: https://github.com/spring-projects/spring-amqp/issues/2652 Also see `TODO` in the `MessagingMessageListenerAdapter` where we won't need to sent that `AmqpHeaders.CHANNEL` any more.

artembilan

I fix this issue https://github.com/spring-projects/spring-amqp/issues/2572 `connectionFactory.isPublisherConfirms()` return condition. I believe this condition is appropriate, **but some people may not think so, as mentioned in the issue above.** Please confirm.

esperar

TraceId propagation to the new thread local

5

The scenario and details are located here: https://github.com/micrometer-metrics/tracing/issues/510#issue-2066891159 Version: 3.1.1

TJackler

### Discussed in https://github.com/spring-projects/spring-amqp/discussions/2571 Originally posted by **bjoernhaeuser** December 15, 2023 Hello everyone, I hope this discussion is at the right place. We are using a CachingConnectionFactory with `CachingConnectionFactory.ConfirmType.SIMPLE` as...

artembilan

Consider replacing with some other mechanism if possible.

garyrussell