Commands | AMQP Get Messages

Mesaj almak Eşzamanlı bir görevdir, bu da sunucuya kuyrukta mesaj olup olmadığını soranın istemci olduğu anlamına gelir. Mesajı Eşzamansız Olarak Alma alternatif yöntemini okuyabilirsiniz.

 

Get Message

GetMessage yöntemi, bir kuyrukta mevcut mesaj olup olmadığını soran AMQP sunucusuna bir istek gönderir. Mesaj varsa bunlar OnAMQPBasicGetOk olayı aracılığıyla gönderilir ve kuyruk boşsa, OnAMQPBasicGetEmpty olayı çağrı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).
• QueueName: kuyruğun adıdır, 255 karakterden uzun olmamalı ve "amq." ile başlamamalıdır (passive parametresi true ise hariç).
• NoWait: true ise, sunucu istemciye bir onay göndermez.

 

AMQP.GetMessage('channel_name', 'queue_name');
 
procedure OnAMQPBasicGetOk(Sender: TObject; const aChannel: string; 
  const aGetOk: TsgcAMQPFramePayload_Method_BasicGetOk; 
  const aContent: TsgcAMQPMessageContent);
begin
  DoLog('#AMQP_basic_GetOk: ' + aChannel + ' ' + IntToStr(aGetOk.MessageCount) + ' ' + aContent.Body.AsString);
end;
 
procedure OnAMQPBasicGetEmpty(Sender: TObject; const aChannel: string);
begin
  DoLog('#AMQP_basic_GetEmpty: ' + aChannel);
end;

Eşzamanlı bir çağrı, sadece GetMessageEx yöntemi çağrılarak yapılabilir, bu yöntem kuyrukta kullanılabilir mesajlar varsa true, aksi takdirde sonuç false olur.