AMQP не может получить сообщение от слушателя

Question

У меня проблема с получением сообщения от слушателя к издателю.Я получаю ** AmqpReplyTimeoutException **.Ниже приведен код издателя, из которого я публикую в очередь.

for(CsvWrapperPojo item : items){

        resultList.addAll(item.getDbResultList());

        for(CSVPojo pojo :item.getQueueRequestList()){




            sampleResponseMessageRabbitConverterFuture= asyncRabbitTemplate.convertSendAndReceive("spring-boot-rabbitmq-Interactive.async_Solve_InteractiveMsg", "Interactive_RequestQueue", pojo);
            //CSVPojo res =(CSVPojo)rabbitTemplate.convertSendAndReceive("spring-boot-rabbitmq-Interactive.async_Solve_InteractiveMsg", "Interactive_RequestQueue", pojo);
            System.out.println("heyyyyyy:" + sampleResponseMessageRabbitConverterFuture.get().getLatitute());
        //resultList.add(res);
        //resultList.add(sampleResponseMessageRabbitConverterFuture.get());
        }

    }

Используя его, я могу опубликовать в очереди, у меня есть код подписчика ниже.

 @EnableRabbit
public class ListenerQueueSubscriber {

    @RabbitHandler
    @RabbitListener(containerFactory = "simpleMessageListenerContainerFactory", queues ="Interactive_RequestQueue")
    public void subscribeToRequestQueue(@Payload CSVPojo sampleRequestMessage, Message message) throws InterruptedException {
    System.out.println("inside listener");
    sampleRequestMessage.setResult("Hello");
    Thread.sleep(120000);
    System.out.println("After sleep:" +sampleRequestMessage.getLongitude());
    //return sampleRequestMessage;
}
}

Byиспользуя вышеупомянутого подписчика, способного прослушать сообщение, и я добавляю " Hello и оставляю в спящем режиме на 2 минуты, и после этого я должен получить сообщение обратно издателю, с которого я опубликовал. Но, к сожалению, не получаю сообщение с Привет добавлено получение ** AmqpReplyTimeoutException **. Может помочь в достижении этого поведения.

Заранее спасибо !!!!