Spring Integration - Adding custom headers in Message

Question

I am using Spring Integration filter to do a structural validation of the incoming payload and if the validation fails then i want to add some custom headers to the original message.

The filter code is below :

@Service("structureValidationFilter")
public class StructureValidationFilter implements MessageSelector {

@Override
public boolean accept(Message<?> message) {
    // TODO Auto-generated method stub
    boolean status=true;

    if(message.getPayload() instanceof CFKRequestBody) {
        CFKRequestBody body=(CFKRequestBody)message.getPayload();
        if(!body.getInitiatingPartyId().equalsIgnoreCase("BPKV")) {
            message = MutableMessageBuilder.fromMessage(message).
                    setHeader("BPKV_ERROR_CODE", "Ïnvalid Initiating part id").
                    setHeader("HTTP_STATUS", "400").build();

            return false;   
        }

    }
    return status;
}

}

But the headers are not populating in the Message. Not able to see the headers added in the next component. What am i doing wrong here.

Gary Russell · Accepted Answer · 2020-02-16 15:28:42Z

1

You can't replace a parameter and expect it to be propagated to the next component; Java doesn't work that way; your new message is simply discarded.

Use a service activator instead of a filter and return the new message, or null which is a signal to end the flow at that point.

edited Feb 16, 2020 at 15:28

answered Feb 16, 2020 at 15:26

Gary Russell

176k14 gold badges168 silver badges194 bronze badges

Sign up to request clarification or add additional context in comments.

4 Comments

MS13 Over a year ago

Used a service activator as an implemention of GenericHandler but got "nested exception is java.lang.UnsupportedOperationException: MessageHeaders is immutable" when tried to modify headers.

Gary Russell Over a year ago

Use MessageBuilder.fromMessage(msg).setHeader(...).setHeader(...).buld();.

MS13 Over a year ago

I did in the end but also the problem was that I was using Object handle(String payload, MessageHeaders headers) instead of Object handle(Message<String> message, MessageHeaders headers) so I was using directly the payload

MS13 Over a year ago

Adding an example would certainly improve this response value

Alexey Khetchikov · Accepted Answer · 2022-12-19 20:03:02Z

1

Your should wrap your result in Message like this

@Override
public Message accept(Message<?> message) {
    // TODO Auto-generated method stub
    boolean status=true;

    if(message.getPayload() instanceof CFKRequestBody) {
        CFKRequestBody body=(CFKRequestBody)message.getPayload();
        if(!body.getInitiatingPartyId().equalsIgnoreCase("BPKV")) {
            return MutableMessageBuilder.fromMessage(message).                        
                    setHeader("BPKV_ERROR_CODE", "Ïnvalid Initiating part id").
                    setHeader("HTTP_STATUS", "400").
                    build();
        }

    }
    return MutableMessageBuilder.fromMessage(message).build();
}

edited Dec 19, 2022 at 20:03

answered Dec 19, 2022 at 19:59

Alexey Khetchikov

112 bronze badges

1 Comment

MS13 Over a year ago

this is not working as method accept from MessageSelector is only returning boolean

Collectives™ on Stack Overflow

Spring Integration - Adding custom headers in Message

2 Answers 2

4 Comments

1 Comment

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

4 Comments

1 Comment

Your Answer

Sign up or log in

Post as a guest

Linked

Related