Приложение My Spring Integration потребляет сообщения от RabbitMQ, преобразует их в сообщение SOAP и выполняет запрос веб-службы. Из очереди можно получать много (10-50) сообщений в секунду. Или после перезапуска приложения в очереди RabbitMQ...

Я хочу обработать сообщение AMQP, а затем отправить его в другую очередь для дальнейшей обработки. Я использую Spring Integration DSL для его архивации, как показано ниже, @Bean public IntegrationFlow ocr(ConnectionFactory connectionFactory,...

Учитывая, что у меня есть IntegrationFlow IntegrationFlows.from( Amqp.inboundAdapter(rabbitConnectionFactory, QUEUE) .messageConverter(new MarshallingMessageConverter(xmlMarshaller))...

Нам нужно передавать сообщения между RabbitMQ и MQSeries. Для этого мы используем конфигурацию ниже. <int:channel id="channelRmqMQ"></int:channel> <int-amqp:inbound-channel-adapter channel="channelRmqMQ"...

Для потоковых служб я хочу, чтобы сообщение оставалось в очереди, когда базовая служба, вызванная в @StreamListener , не работает. С этой целью, насколько я понимаю, единственный способ сделать это - настроить...

Я использую весеннюю интеграцию (с адаптерами входящего / исходящего каналов) для передачи сообщений из JMS в AMQP AMQP в JMS AMQP в AMQP Это прекрасно работает. Когда очередь назначения заполнена, я хотел бы остановить процесс и...

Учитывая, что у меня IntegrationFlow : IntegrationFlows.from( Amqp.inboundAdapter(rabbitConnectionFactory, NTF_INCOMING_CMSF_EVENT_QUEUE) .messageConverter(new Jackson2JsonMessageConverter(jacksonObjectMapper)) ) .get() Я...

У меня есть поток интеграции, определенный следующим образом: IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "queueName") .id("id") .autoStartup(autoStartup)...

Я только что обновил свое приложение до версии spring-integration-amqp-5.2.4.RELEASE , и когда я получаю сообщение из очереди, все работает нормально, но я заметил предупреждение java.lang.ClassNotFoundException в классе DefaultAmqpHeaderMapper ....

У меня есть поток интеграции Spring, определенный следующим образом: IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "queueName") .id("id") .acknowledgeMode(MANUAL)...

Теперь я хотел бы реализовать эту идею с помощью RabbitMQ и Spring Integration: Одна очередь, вместимостью 1 сообщение. Потребители будут запрашивать это сообщение, если оно существует в очереди, оно будет доставлено им, если нет, они получат...

Создаю поток, который потребляет сообщения от RabbitMQ и после этого раздает на соответствующие сервисы по типам с помощью роутера. Методы в сервисах принимают аргумент Message<?> , потому что там мне нужно использовать заголовки. Но в этом...

У меня есть 10 очередей rabbitMQ, называемых event.q.0, event.q.2, ‹...>, event.q.9. Каждая из этих очередей получает сообщения, перенаправленные из обмена event.consistent-hash. Я хочу создать отказоустойчивое решение, которое будет последовательно...