Использование нескольких сообщений из двух разных очередей с использованием @StreamListener в RabbitMQ

Question

У меня есть две очереди, которые могут создавать сообщения в очереди RabbitMQ. Теперь я хочу использовать эти сообщения из той же потребительской службы на основе действия. Одна очередь была создана при добавлении пользователем какого-либо элемента, а другая - при попытке пользователя удалить из пользовательского интерфейса. Я могу использовать одно сообщение с помощью @StreamListener, но как использовать оба сообщения с помощью @StreamListener?

в классе Consumer:

    @StreamListener(target = Sink.INPUT)
        public void processRegisterAdd(String message) throws JsonParseException, JsonMappingException, IOException {
            System.out.println("for adding item message in queue: " + message);

        }


 /* @StreamListener(target = Sink.INPUT)
            public void processRegisterDelete(String message) throws JsonParseException, JsonMappingException, IOException {
                System.out.println("for deleting item message in queue: " + message);

            }*/

в приложении Consumer.properties:

spring.cloud.stream.bindings.input.destination=itemRetrival
spring.cloud.stream.bindings.input.group=itemRetrivalQueue

Как использовать оба сообщения в зависимости от действия в классе Consumer, используя @ StreamListener.