spring-amqp

0зной

1ответ

не в состоянии обработать ответ, полученный от template.convertSendAndReceive()

Я пытаюсь отправить сообщение и получить ответ, используя следующий код MessageProperties props =MessagePropertiesBuilder.newInstance().setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN)

1зной

1ответ

Пружинный автомат таймераOnce() переход прерывания действий выхода

У меня есть следующий автомат; @Configuration @EnableStateMachineFactory public class StateMachineConfig extends EnumStateMachineConfigurerAdapter<GameStep, GameEventType> { @Autowired pr

0зной

1ответ

Spring AMQP convertSendAndReceive с успокоительной многопоточных производителя

Я пытаюсь решить, будет ли convertSendAndReceive работать для следующего случая использования: У меня есть RESTful веб-сервис, который необходимо сделать RPC вызовы и получить ответ обратно в для обсл

1зной

2ответ

Spring Amqp Consumer приостанавливается после запуска на некоторое время

У нас есть кластер с двумя узлами RabbitMQ с политикой Ha-all. Мы используем Spring AMQP в нашем приложении для общения с RabbitMQ. Часть производителя работает нормально, но потребитель работает неко

2зной

1ответ

SpringAMQP Создание очереди с помощью args

Я создал очередь с аргументами истечения сообщения, но при запуске сервера я получил следующую ошибку. [SimpleAsyncTaskExecutor-1] o.s.a.r.c.RabbitAdmin [RabbitAdmin.java:375] Auto-declaring a non-dur

1зной

2ответ

SpringAMQP delay

У меня возникли проблемы с определением способа задержки уровня сообщений в SpringAMQP. Я вызываю Webservice, если служба недоступна или если она генерирует некоторое исключение, я сохраняю все запрос