Ability to configure auto-startup on a per @RabbitListener basis about spring-amqp HOT 6 CLOSED

We could add autoStartup to the @RabbitListener itself, if set it would override the default.

BTW, for your workaround, if you want the other boot properties applied to your container factory, you should pass it to the configurer as is done in the boot autoconfig.

	@Bean
	@ConditionalOnMissingBean(name = "rabbitListenerContainerFactory")
	public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
			SimpleRabbitListenerContainerFactoryConfigurer configurer,
			ConnectionFactory connectionFactory) {
		SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
		configurer.configure(factory, connectionFactory);
		return factory;
	}

You really don't need a subclass, just set the factory's autoStartup to false after the configurer has done its work.

from spring-amqp.

AMQP-774.

from spring-amqp.

Does this work for you

/**
	 * If provided, the listener container for this listener will be added to a bean
	 * with this value as its name, of type {@code Collection<MessageListenerContainer>}.
	 * This allows, for example, iteration over the collection to start/stop a subset
	 * of containers.
	 * @return the bean name for the group.
	 * @since 1.5
	 */
	String group() default "";

?

from spring-amqp.

@artembilan I definitely looked at the group feature but unfortunately had no luck.

The listener is already started by the time I get access to the Collection<MessageListenerContainer> and if there's items already in the queue, I run the risk of them being consumed before I can call stop().

I tried getting access to the Collection<MessageListenerContainer> earlier in the process via the ContextRefreshed event but that hook is called after a context refresh. Ideally ... something like a BeforeContextRefresh event would work but I couldn't find one.

from spring-amqp.

Let's try this!

@Autowired
@Qualifier("myGroup")
Collection<AbstractMessageListenerContainer> containers;

@PostConstruct
public void setup() {
     this.containers.forEach(c -> c.setAutoStartup(false));
}

from spring-amqp.

Awesome! Thanks for the help guys and thanks for the awesome framework.

from spring-amqp.