When the consumer is set to exclusive and multiple instances are started, the console

Exclusive Consumer Logging Improvements about spring-amqp HOT 3 CLOSED

zhangheng0027 commented on April 28, 2024

Exclusive Consumer Logging Improvements

from spring-amqp.

Comments (3)

garyrussell commented on April 28, 2024

This is a reasonable request, but consider setting Single Active Consumer on the queue rather than using exclusive consumers; it is more efficient and avoids this problem.

https://www.rabbitmq.com/consumers.html#single-active-consumer

Difference from Exclusive Consumers

Compared to AMQP 0-9-1 exclusive consumer, single active consumer puts less pressure on the application side to maintain consumption continuity. Consumers just need to be registered and failover is handled automatically, there's no need to detect the active consumer failure and to register a new consumer.

from spring-amqp.

garyrussell commented on April 28, 2024

By the way, the WARN log can be avoided by setting a custom logger here:

	/**
	 * Set a {@link ConditionalExceptionLogger} for logging exclusive consumer failures. The
	 * default is to log such failures at WARN level.
	 * @param exclusiveConsumerExceptionLogger the conditional exception logger.
	 * @since 1.5
	 */
	public void setExclusiveConsumerExceptionLogger(ConditionalExceptionLogger exclusiveConsumerExceptionLogger) {

The INFO logs for the restart can be avoided by setting the container's logger level to WARN.

from spring-amqp.

garyrussell commented on April 28, 2024

There is also a closeExceptionLogger on the connection factory:

	/**
	 * Set the strategy for logging close exceptions; by default, if a channel is closed due to a failed
	 * passive queue declaration, it is logged at debug level. Normal channel closes (200 OK) are not
	 * logged. All others are logged at ERROR level (unless access is refused due to an exclusive consumer
	 * condition, in which case, it is logged at INFO level).
	 * @param closeExceptionLogger the {@link ConditionalExceptionLogger}.
	 * @since 1.5
	 */
	public void setCloseExceptionLogger(ConditionalExceptionLogger closeExceptionLogger) {