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->{});
}
}Code language: JavaScript (javascript)- 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ünyaRabbitMQ’de kuyrukta bekleyen mesajımızı okumuş olduk.
Sonraki yazıda görüşmek üzere