Stack Overflow
Stack Overflow

Questions tagged [spring-integration-amqp]

73 questions
9
votes
3 answers

RabbitHealthIndicator - Health check failed

Have a similar situation as we have here Spring Cloud Stream and RabbitMQ health check Error message 2018-12-04 05:17:31.768 INFO 1 --- [nio-8080-exec-6] o.s.a.r.c.CachingConnectionFactory : Attempting to connect to:…
Hhovhann
  • 511
  • 1
  • 6
  • 22
9
votes
1 answer

Spring Integration error "no output-channel or replyChannel header available"

I am not sure why I am getting the exception Caused by: org.springframework.messaging.core.DestinationResolutionException: no output-channel or replyChannel header available Its just a simple IntegrationFlow but not sure what am I missing here in…
Wizard
  • 1,154
  • 2
  • 14
  • 41
6
votes
3 answers

How can @MessagingGateway be configured with Spring Cloud Stream MessageChannels?

I have developed asynchronous Spring Cloud Stream services, and I am trying to develop an edge service that uses @MessagingGateway to provide synchronous access to services that are async by nature. I am currently getting the following stack…
Keith Bennett
  • 733
  • 11
  • 25
5
votes
1 answer

Spring Cloud Stream and RabbitMQ health check

I have a simple Spring Boot application using Spring Cloud Stream Rabbit and Eureka Discovery Client. The application works fine together with Eureka Server, and the messaging over RabbitMQ is also working. But if I spin up a Spring Boot Admin…
Jaffa
  • 501
  • 1
  • 8
  • 16
3
votes
1 answer

How to handle errors when RabbitMQ exchange doesn't exist (and messages are sent through a messaging gateway interface)

I'd like to know what is the canonical way to handle errors in the following situation (code is a minimal working example): Messages are sent through a messaging gateway which defines its defaultRequestChannel and a @Gateway…
Enrico M. Crisostomo
  • 1,653
  • 1
  • 17
  • 26
3
votes
1 answer

How to dynamically add queue to exchange in Spring Integration

I have the following exchange in integrationcontext.xml …
omexIT
  • 111
  • 8
3
votes
1 answer

How to declare two outbound-channel-adapter for publishing different message

I have declared int:chain with single input and output channel, …
Vigneshwaran
  • 782
  • 2
  • 7
  • 22
2
votes
1 answer

Spring Boot/RabbitMQ avoid unack msg

@RabbitListener(queues="XYZ") public void rabbitMsgReceiver(@Payload final UserProfile up, Message msg, Channel channel) { } If the message that is received is not a valid JSON of UserProfile, then ListenerExecutionFailedException occurs and the…
Prashant
  • 97
  • 3
  • 11
2
votes
1 answer

Does Spring Integration Support Azure Service Bus?

I need to use Azure Service Bus for messaging, and would like to try out Spring Integration AMQP support. I can't find any related examples or anything to suggest this is possible.
Rich Cowin
  • 668
  • 1
  • 8
  • 17
2
votes
1 answer

Spring integration Java DSL - Dynamically create IntegrationFlows

I'm working on an application using Spring Boot 1.5.13.RELEASE and Spring Integration 4.3.16.RELEASE. I'm pretty new to Spring Integration and I have encountered a problem. So the basic idea is that on some external triggers (could be and HTTP call)…
Alexreve
  • 46
  • 1
  • 5
2
votes
1 answer

How to manually acknowledge RabbitMQ messages in Spring Cloud Stream?

For stream-based services, I want the message to remain in the queue when the underlying service invoked within a @StreamListener fails. To that end, my understanding is that the only way to do this is to configure…
Keith Bennett
  • 733
  • 11
  • 25
2
votes
1 answer

The 'sequenceNumber' header value must be an Integer. But it is Long

I'm using the RabbitMQ 3.6.10 UI to publish a message that is received by my Java application that uses Spring Integration AMQP 4.3.11. The message is a reply to an earlier message that was created using a Splitter, so it had a sequenceNumber and…
Adam Michalik
  • 9,678
  • 13
  • 71
  • 102
1
vote
1 answer

spring integration: process input messages in parallel by partition key

I have a simple spring integration flow receiving a message from an AmqpInboundChannelAdapter. After some transformations, the messages must be put into an AWS Kinesis data stream. @Bean public AmqpInboundChannelAdapter…
roby.s
  • 21
  • 6
1
vote
1 answer

Spring Integration - Control retry logic in http outboundAdapter

I configured a route in Spring Integration 5.4.4 that read from an AMQP queue and write to an http outbound adapter. I'm not able to control retries when, for example, I programmatically declare a wrong http hostname for the http outbound adapter…
tosky
  • 31
  • 3
1
vote
1 answer

Spring Batch Integration consuming RabbitMq Message

I am currently using an IntegrationFlow to trigger a Job execution when RabbitMq messages arrive in a queue. Both the IntegrationFlow's AmqpInboundChannelAdapter and the job's first step's ItemReader are configured to read messages from the same…
Thomas Märkl
  • 13
  • 2
1
2 3 4 5