rabbitmq_delayed_message_exchange

• 메세지를 바로 소비하는게 아니라 약간의 시간차를 두고 싶을 때 사용

설치

• https://jiyeonseo.gitbooks.io/daily/content/amqp/plugins.html

설정 방법

1. exchange 탭에서 를 만든다.
   

2. Type : x-delayed-message

3. Arguments : x-delayed-type

4. 메세지 보낼때 'x-delay' 값을 message-peroperties에 넣어준다.

// spring-amqp 사용
byte[] messageBodyBytes = "message".getBytes();
MessageProperties mProperties = new MessageProperties();

mProperties.setDelay(10000); // milliseconds
Message msg = new Message(messageBodyBytes, mProperties);

rabbitTemplate.send("delay.test","", msg); // exchange, routring key, message

ref : https://www.rabbitmq.com/blog/2015/04/16/scheduling-messages-with-rabbitmq/