AMQP Consume Messages

Os consumidores consomem de filas. Para consumir mensagens, deve haver uma fila. Quando um novo consumidor é adicionado, supondo que já existam mensagens prontas na fila, as entregas começarão imediatamente.

A fila de destino pode estar vazia no momento do registro do consumidor. Nesse caso, as primeiras entregas ocorrerão quando novas mensagens forem enfileiradas.

 

Consumir mensagens é uma tarefa assíncrona, o que significa que toda vez que uma nova mensagem pode ser entregue à fila do consumidor, ela é enviada pelo servidor ao cliente automaticamente. Você pode ler um método alternativo em Receber Mensagem de Forma Síncrona.

 

Consume

O método Consume cria um novo consumidor na fila, e toda vez que houver uma nova mensagem, ela será entregue automaticamente ao cliente consumidor.

 

O método tem os seguintes argumentos:

 

• ChannelName: é o nome do canal (deve estar aberto antes de chamar este método).
• QueueName: é o nome da queue, não deve ter mais de 255 caracteres e não começar com "amq." (exceto se o parâmetro passive for true).
• ConsumerTag: é o nome do consumidor e deve ser único. Se não for definido, o servidor cria um novo.
• NoLocal: se true, significa que o consumidor nunca consome mensagens publicadas no mesmo canal.
• NoAck: se true, significa que o servidor não espera uma confirmação para cada mensagem entregue.
• Exclusive: se true, impede que outros consumidores consumam mensagens desta fila.
• NoWait: se true, o servidor não enviará uma confirmação ao cliente.
• Arguments: string que contém argumentos personalizados, os valores devem ser passados como uma string json, exemplo: {"x-dead-letter-exchange":"my-dlx"}.

 

As mensagens são entregues no evento OnAMQPBasicDeliver .

 

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;

Uma chamada Síncrona pode ser feita apenas chamando o método ConsumeEx; este método retorna true se o Consumer foi criado e false se nenhuma confirmação do servidor chegou.

 

Cancel Consume

Este método é usado para Cancelar uma fila de consumidor existente.

 

O método tem os seguintes argumentos:

 

• ChannelName: é o nome do canal (deve estar aberto antes de chamar este método).
• ConsumerTag: é o nome do consumidor.
• NoWait: se true, o servidor não enviará uma confirmação ao cliente.

 

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

Uma chamada síncrona pode ser feita simplesmente chamando o método CancelConsumeEx; este método retorna true se o Consumer foi cancelado e false se nenhuma confirmação do servidor chegou.