Send message TTL in header using spring cloud stream rabbit mq binder

Viewed 30

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);
1 Answers
Related