Delayed Exchange

Rabbit1Application.java

package com.example.demo;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.ExchangeBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class Rabbit1Application {

	public static void main(String[] args) {
		SpringApplication.run(Rabbit1Application.class, args);
	}

	@Bean
	public DirectExchange exchange() {
		return ExchangeBuilder.directExchange("delayed")
				.delayed()
				.build();
	}

	@Bean
	public Queue queue() {
		return QueueBuilder.durable("queue").build();
	}

	@Bean
	public Binding binding() {
		return BindingBuilder.bind(queue()).to(exchange()).with("routing.key");
	}

	@RabbitListener(queues = "queue")
	public void listen(String in) {
		System.out.println(in);
	}

	@Bean
	public ApplicationRunner runner(RabbitTemplate template) {
		return args -> template.convertAndSend("delayed", "routing.key", "foo", msg -> {
			msg.getMessageProperties().setDelay(8000);
			System.out.println("Sending");
			return msg;
		});
	}

}