spring-amqp

spring-amqp copied to clipboard

The CachingConnectionFactory findOpenChannel message lock contention is severe

3

I get **22,900/second** with this app... ```java @SpringBootApplication public class Gh644Application implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(Gh644Application.class, args).close(); } @Autowired private RabbitTemplate template; @Autowired private RabbitListenerEndpointRegistry...

missence

Similar to https://github.com/spring-projects/spring-kafka/issues/1872 Related to https://github.com/spring-projects/spring-amqp/issues/1544

garyrussell

**[Mark Fisher](https://jira.spring.io/secure/ViewProfile.jspa?name=mark.fisher)** opened **[AMQP-42](https://jira.spring.io/browse/AMQP-42?redirect=false)** and commented This will be used by MessageConverters, RabbitTemplate, etc. We should follow this fallback logic: 1) explicit 'messageFactory' property has been set (e.g. on a...

spring-operator

SimpleMessageListenerContainer should be offer more aggressive scale down options [AMQP-745]

10

**[Yannick](https://jira.spring.io/secure/ViewProfile.jspa?name=yenki)** opened **[AMQP-745](https://jira.spring.io/browse/AMQP-745?redirect=false)** and commented This is somehow related to #2259 Unless we set 'consecutiveIdleTrigger' to 1 and an ridiculously low receiveTimeout, it's very hard to have consumers removed from...

spring-operator

Use one RabbitTemplate for both `send()` and `sendAndRecieve()` with a fixed reply queue. [AMQP-480]

3

**[Scott Frederick](https://jira.spring.io/secure/ViewProfile.jspa?name=scottyfred)** opened **[AMQP-480](https://jira.spring.io/browse/AMQP-480?redirect=false)** and commented It is currently not possible to use the same instance of a RabbitTemplate to both `send()` and `sendAndRecieve()` using multiple fixed reply queues. When...

spring-operator

Expose method for declaring multiple Declarable objects [AMQP-842]

4

**[Alen Turkovic](https://jira.spring.io/secure/ViewProfile.jspa?name=alturkovic)** opened **[AMQP-842](https://jira.spring.io/browse/AMQP-842?redirect=false)** and commented `org.springframework.amqp.rabbit.core.RabbitAdmin` already has a method for declaring multiple queues but exposes a method for declaring a single one: `RabbitAdmin#declareQueue(Queue)` The same goes for `Queue`,...

spring-operator

**[Konrad Grüner](https://jira.spring.io/secure/ViewProfile.jspa?name=konraifen88)** opened **[AMQP-803](https://jira.spring.io/browse/AMQP-803?redirect=false)** and commented Referencing to my GitHub issue: It would be great to have two interfaces for the message post processing, for example: * `MessageReceivePostProcessor` * `MessageSendPostProcessor`...

spring-operator

Add logback appender for access event [AMQP-802]

2

**[Youssef Foullous](https://jira.spring.io/secure/ViewProfile.jspa?name=yfoullous)** opened **[AMQP-802](https://jira.spring.io/browse/AMQP-802?redirect=false)** and commented There is a logback appender that publishes logging events `ILoggingEvent`. It would be nice to have the same thing to publish access events `IAccessEvent`...

spring-operator

Consider adding dynamic scaling of consumers to DirectMessageListenerContainer [AMQP-707]

1

**[Zahari Dichev](https://jira.spring.io/secure/[email protected])** opened **[AMQP-707](https://jira.spring.io/browse/AMQP-707?redirect=false)** and commented If we look at what the `SimpleMessageListenerContainer` does in order to determine whether we should scale consumers or not, we will quickly find out...

spring-operator

Improve Documentation for PooledChannelConnectionFactory

9

**In what version(s) of Spring AMQP are you seeing this issue?** Tested with 2.4.3 and 2.4.8 **Describe the bug** We have a Spring Boot application that uses a `PooledChannelConnectionFactory` and...

m-ober