I want to use spring cloud stream rabbitMQ binder for message driven architecture. But each message should have own time to live setting. so I need to give this setting in message header. Do you think is this possible using Spring Cloud Stream RabbitMQ Binder ?
Message message1 = MessageBuilder.withPayload(new PFSimulationEvent(1, "sd"))
.setHeader("to_process", true).setHeader("expiration", 10000)
.build();
output.send("simulatePf-out-0", message1);