Delayers
As we already discussed in the introduction section, there could be a difference in the rate of messages produced and its rate of consumption—what if the consumer is slow? Since external systems are involved, it might not be in our control to influence the rate at which the producer produces messages. This is where a delayer is used. A delayer is a simple endpoint that introduces a delay before the message is delivered to the next endpoint. The most notable part is that the original sender is neither blocked nor slowed down; rather, the delayer will pick a message from a channel and use an instance of org.springframework.scheduling.TaskScheduler to schedule its delivery to the output channel after a configured interval. Let's write a ...
Become an O’Reilly member and get unlimited access to this title plus top books and audiobooks from O’Reilly and nearly 200 top publishers, thousands of courses curated by job role, 150+ live events each month,
and much more.
Read now
Unlock full access