Closed. This question is opinion-based. It is not currently accepting answers. Want to improve this question? Update the question so it can be answered with facts and citations by editing this post. Closed 9 months ago. Improve this question I’m implementing Transactional Outbox pattern using Java. The …
Tag: spring-integration
Spring Integration with Kafka throwing ClassCastException
I have a case where i want to publish message from Kafka Producer, My message is just a POJO object e.g CreateRequest. So for consuming I have added below code Also,I have added setMessageConverter and setPayloadType to get response of type CreateResponse but still i am getting response of type KafkaMessageSo…
Handle inbound AMQP messages based on a header attribute (e.g. routing key)
I have a service, that receives AMQP messages. This service is bound to a queue, which receives all messages which match a set of routing keys. My set up is as follows: This already works fine. However, now I want to handle a message with different controllers, depending on a header attribute. In this case I&…
Converting java object to xml
How can i convert java object to xml? I am trying to convert an incoming java object to xml in spring integration with a converter bean. is there another way than marshalling in Jaxb ? like using @TypeConverter. Or implementing converter class. Answer I’m not familiar with @TypeConverter, but looks that…
How To Stop Polling InboundChannelAdapter
Im polling files from 2 different directories in 1 server using RotatingServerAdvice and that´s working fine, the problem is that I can´t stop polling once time I start the inboundtest.start (). The main idea is retrive all the files in those directories, and then send inboundtest.stop (), this is the code. A…
Pub/Sub Spring integration Queue Channel no poller defined
I have an application that connects to a pub/sub and processes messages when the pub/sub subscription publishes. I want to be able to put these messages into a Queue Channel to avoid processing loads of messages at once. However, when i try to add a queue channel i get the below error ? So the way i see it, a
How can I create http inbound channel adapter with JAVA config in Spring integration?
I have the following http inbound channel adapter. How can I do this configuration with Java Config or Spring DSL? Answer See Spring Integration Reference Manual: Java DSL at all: https://docs.spring.io/spring-integration/docs/current/reference/html/dsl.html#java-dsl HTTP Module specifics: https://docs.spring…
Strange error with WebFlux and Spring-Integration – IndexOutOfBoundsException exceeds maxCapacity
I am in the process of writing a spring-integration flow that is intended to enrich the headers of a message based on the determination if a remote resource actually exists. Assuming that there is a RESTful endpoint that has an API on it that will locate an object based on a unique name: /mix-entity/name/{mix…
Spring Integration file only once from SFTP across several sessions
I have a Spring Integration WorkFlow which downloads files from a SFTP directory. This is done with a RemoteFileInboundChannelAdapterSpec and IntegrationFlows. Spring Integration remembers within a session which files it has already downloaded, can I do this across sessions e.g. through a database and if so h…
Spring Integration: how to configure ObjectToJsonTransformer to add json__TypeId__ with class name instead of canonical name
I am trying to serialize a message (then deserialize it) and I do not want any of the headers json__TypeId__ or json_resolvableType to contain the canonical name of the class. This is because I am sending the message over the network and I consider including the canonical name in the header a security concern…