Spring Cloud Stream - Потреблять данные по запросу вручную?

Question

Используя Spring Data Stream, Как я могу начать чтение из очереди и остановить чтение по требованию?

Я хочу, чтобы что-то вроде этого:

@EnableBinding(Sink.class)
public class SomeConsumer {

  @StreamListener(target = Sink.INPUT)
  public void receiveMsg(Message<String> message)
  {
    logger.info(" received new message [" + message.toString() + "] ");
  }

  public static void startReceiving()
  {
     //How to implement this logic?
  }

  public static void stopReceiving()
  {
     //How to implement this logic?
  }

}

Answer 1

Это невозможно сделать с помощью метода c; автоматически подключите BindingsEndpoint и используйте метод changeState().

См. мой ответ на этот вопрос .