RabbitMQ Java Consumer Uygulaması

RabbitMQ Dersleri‘ne devam ediyorum.

Önceki yazıda Publisher uygulaması yaptık ve RabbitMQ’ya mesajımızı yolladık. Yolladığımız bu mesajı queue’dan okuyabilmemiz için bir consumer uygulaması yapacağız.

Consumer uygulamamızı oluşturalım ve sonrasında neler yaptık bakalım.

Yapacağımız uygulama sürekli olarak RabbitMQ’deki belirlediğimiz

public class Consumer {
    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory connectionFactory = new ConnectionFactory();
        Connection connection = connectionFactory.newConnection();

        Channel channel = connection.createChannel();

        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody());
            System.out.println("Message recived " + message);
        };
        channel.basicConsume( "Kuyruk-1",true, deliverCallback, consumerTag->{});
    }
}

• ConnectionFactory

Connection Factory RabbitMQ’ya bağlanmak için gerekli connection bilgisini oluşturulur.

• Connection

Connection Factory ile yeni bir connection sağlanır.

• Channel

RabbitMQ’daki erişmemiz gereken kanal bilgisini sağlamaktadır.

• DeliverCallback

Okuayacak mesaj içeriğini almamazı sağlamaktadır. Gelen mesajın body’sini alarak iş akışımıza göre handle edebilmekteyiz.

• basicConsume

RabbitMQ’tan okumak isteğimiz kanal ve queue’ya bilgisini yazıyoruz.

Uygulamızın console çıktısına bakalım.

Merhaba Dünya

RabbitMQ’de kuyrukta bekleyen mesajımızı okumuş olduk.

Sonraki yazıda görüşmek üzere