Posts

Showing posts with the label spring-integration-dsl

Spring Integration : Remove Jms and Http Headers from Message

Image
Clash Royale CLAN TAG #URR8PPP Spring Integration : Remove Jms and Http Headers from Message I have a integration flow like this Subscriber & Publisher Broker->queue1->Transform->HTTP CALL->HTTP Response->JMS Message->Broker->queue2 This my integration flow DSL @Bean public IntegrationFlow orchestrationFlow() { return IntegrationFlows.from(Jms.messageDrivenChannelAdapter(connectionFactory).destination("MAILBOX")) //destination("amq.outbound1")) .<String, String>transform(s -> { return s.toLowerCase(); }).log() .transform(new PojoTransformer()) //.headerFilter("^(jms?|JMS)://.*$", true) .log() // HTTP part goes here .<String, HttpEntity<String>>transform(HttpEntity::new).handle( Http.outboundGateway("http://localhost:8080/uppsercase").httpMethod(HttpMethod.POST) ...