Since we have filters as end-point in spring integration, can't we add a filter as end-point for the messages that needs to be consumed
just a thought, sorry if it was silly answer