Manual start and stop of container about rqueue HOT 4 CLOSED

Hi @longveeshaw
It's guaranteed that a message would be delivered at least once to the application/listener(s). It comes with a graceful shutdown, all listeners would be stopped at the time of shutdown. The time takes for shutdown can vary based on the number of currently running tasks, application shutdown waits for the executing task to be executed/terminated but in some cases it might timeout as shutdown process can't be halt for many minutes or so.

Could you provide some more context about ?

Can the queue stop or start according the configuration?

from rqueue.

Hi @longveeshaw
It's guaranteed that a message would be delivered at least once to the application/listener(s). It comes with a graceful shutdown, all listeners would be stopped at the time of shutdown. The time takes for shutdown can vary based on the number of currently running tasks, application shutdown waits for the executing task to be executed/terminated but in some cases it might timeout as shutdown process can't be hold for many minutes or so.

Could you provide some more context about ?

Can the queue stop or start according the configuration?

@sonus21

Just like kafka :
MessageListenerContainer listenerContainer = kafkaListenerEndpointRegistry.getListenerContainer(listenerId);
// if need to start listen,just write listenerContainer.start()
listenerContainer..start();
// if need to stop listen,just write listenerContainer.stop;
listenerContainer.stop();

if this command is available,when we need to deploy a new application,we can first stop all listeners,then stop old application,after the new application started, just start the listeners again.

from rqueue.

IIUC, you're looking for manual start and stop of container, It does support manual start and stop, but not at consumer level, it will start all consumer and stop all consumers/listeners.

Create SimpleRqueueListenerContainerFactory with autoStart=false, this will create a container of type RqueueMessageListenerContainer. Once this bean is created with auto start is false, then you can control containers using start and stop methods.

 @Bean
  public SimpleRqueueListenerContainerFactory simpleRqueueListenerContainerFactory(
      RedisConnectionFactory redisConnectionFactory, RqueueMessageHandler rqueueMessageHandler) {
    SimpleRqueueListenerContainerFactory factory = new SimpleRqueueListenerContainerFactory();
    factory.setAutoStartup(false);
    factory.setRedisConnectionFactory(redisConnectionFactory);
    factory.setRqueueMessageHandler(rqueueMessageHandler);
    return factory;
  }

This will create a bean of typeRqueueMessageListenerContainer , you can use that bean in your application to manually start and stop.

public class BootstrapController {
    @Autowired RqueueMessageListenerContainer rqueueMessageListenerContainer;

    // ... 
    public void start() {
      /// do something
      rqueueMessageListenerContainer.start();
    }
   public void stop() {
      // do something
      rqueueMessageListenerContainer.stop();
    }
  }

from rqueue.

support

ok,i will have a try. Tks

from rqueue.