AMQP Consume Messages

Tüketiciler kuyruklardan tüketir. Mesajları tüketmek için bir kuyruk olmalıdır. Yeni bir tüketici eklendiğinde, kuyrukta zaten hazır mesajlar olduğu varsayılarak, teslimler hemen başlar.

Hedef kuyruk, tüketici kaydı sırasında boş olabilir. Bu durumda ilk teslimatlar yeni mesajlar kuyruğa alındığında gerçekleşir.

 

Mesajları tüketmek asenkron bir görevdir; bu, tüketici kuyruğuna her yeni mesaj teslim edilebildiğinde, sunucu tarafından istemciye otomatik olarak gönderildiği anlamına gelir. Mesajı Senkronize Olarak Alma için alternatif bir yöntem okuyabilirsiniz.

 

Consume

Consume yöntemi kuyrukta yeni bir tüketici oluşturur ve her yeni mesaj olduğunda bu, tüketici istemcisine otomatik olarak teslim edilir.

 

Yöntemin aşağıdaki argümanları vardır:

 

• ChannelName: kanalın adıdır (bu yöntem çağrılmadan önce açılmış olmalıdır).
• QueueName: queue'nun adıdır, 255 karakterden uzun olmamalı ve "amq." ile başlamamalıdır (passive parametresi true ise hariç).
• ConsumerTag: consumer'ın adıdır ve benzersiz olmalıdır. Ayarlanmazsa, sunucu yeni bir tane oluşturur.
• NoLocal: true ise, tüketicinin aynı kanalda yayımlanan mesajları asla tüketmediği anlamına gelir.
• NoAck: true ise, sunucunun teslim edilen her mesaj için bir onay beklemediği anlamına gelir.
• Exclusive: true ise, diğer tüketicilerin bu kuyruktan mesaj tüketmesini engeller.
• NoWait: true ise, sunucu istemciye bir onay göndermez.
• Arguments: özel argümanlar içeren string, değerler bir json string'i olarak geçirilmelidir, örnek: {"x-dead-letter-exchange":"my-dlx"}.

 

Mesajlar OnAMQPBasicDeliver olayı aracılığıyla teslim edilir.

 

AMQP.Consume('channel_name', 'queue_name', 'consumer_tag');
 
procedure OnAMQPBasicDeliver(Sender: TObject;
  const aChannel: string;
  const aDeliver: TsgcAMQPFramePayload_Method_BasicDeliver;
  const aContent: TsgcAMQPMessageContent);
begin
  DoLog('#AMQP_basic_deliver: ' + aChannel + ' ' + aDeliver.ConsumerTag + ' ' +
    ' ' + aContent.Body.AsString);
end;

ConsumeEx yöntemini çağırarak senkron bir çağrı yapılabilir, bu yöntem Consumer oluşturulmuşsa true ve sunucudan onay gelmemişse false döndürür.

 

Cancel Consume

Bu yöntem, mevcut bir tüketici kuyruğunu İptal etmek için kullanılır.

 

Yöntemin aşağıdaki argümanları vardır:

 

• ChannelName: kanalın adıdır (bu yöntem çağrılmadan önce açılmış olmalıdır).
• ConsumerTag: tüketicinin adıdır.
• NoWait: true ise, sunucu istemciye bir onay göndermez.

 

AMQP.CancelConsume('channel_name', 'consumer_tag');
 
procedure OnAMQPBasicCancelConsume(Sender: TObject; const aChannel: string; const aConsumerTag);
begin
  DoLog('#AMQP_basic_cancel_consume: ' + aChannel + ' ' + aConsumerTag);
end;

Senkron bir çağrı, yalnızca CancelConsumeEx yöntemi çağrılarak yapılabilir; bu yöntem, Consumer iptal edilmişse true, sunucudan onay gelmemişse false döndürür.