Código 7

@EnableBinding({Processor.class})
public class PaymentProcessor {
   private final Logger LOGGER = LoggerFactory.getLogger(PaymentProcessor.class);

   @SendTo(Processor.OUTPUT)
   @StreamListener(target = Processor.INPUT)
   public Message<Map<String, Object>> processPayment(Message<Map<String, Object>> paymentApprovalRequest) {
       Map<String, Object> request = paymentApprovalRequest.getPayload();

      ………..

       return MessageBuilder.withPayload(request)
               .setHeader("notificationPriority", priority)
               .build();
   }

}