Spring Amqp RabbitMQ MessageBuilder Sınıfı

Giriş

Şu satırı dahil ederiz

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageBuilder;
import org.springframework.amqp.core.MessageDeliveryMode;

setDeliveryMode metodu

Örnek - PERSISTENT

Şöyle yaparız

Message sysErrMsg = MessageBuilder.withBody(systemErrorLog.getBytes())
                      .setDeliveryMode(MessageDeliveryMode.PERSISTENT)
                      .build();

Örnek - NON_PERSISTENT

Şöyle yaparız

Message sysErrMsg = MessageBuilder.withBody(systemErrorLog.getBytes())
                      .setDeliveryMode(MessageDeliveryMode.NON_PERSISTENT)
                      .build();

setMessageId metodu

Örnek

Şöyle yaparız.

Message message = MessageBuilder.withBody(messageText.getBytes())
            .setMessageId("123")
            .setContentType("application/json")
            .setHeader("foo", "bar")
            .build();