AMQP Consume Messages

소비자는 큐에서 소비합니다. 메시지를 소비하려면 큐가 있어야 합니다. 새 소비자가 추가될 때 큐에 이미 준비된 메시지가 있다고 가정하면 전달이 즉시 시작됩니다.

대상 큐는 소비자 등록 시점에 비어 있을 수 있습니다. 이 경우 새 메시지가 큐에 추가될 때 첫 전달이 발생합니다.

 

메시지 소비는 비동기 작업이며, 이는 새 메시지가 소비자 큐에 전달될 수 있을 때마다 서버에 의해 자동으로 클라이언트로 푸시됨을 의미합니다. 동기적으로 메시지 수신하는 대체 방법을 읽을 수 있습니다.

 

Consume

Consume 메서드는 큐에 새 소비자를 생성하며, 새 메시지가 있을 때마다 이것이 소비자 클라이언트에게 자동으로 전달됩니다.

 

메서드에는 다음 인수가 있습니다:

 

• ChannelName: 채널의 이름입니다(이 메서드를 호출하기 전에 열려 있어야 함).
• QueueName: 큐의 이름입니다. 255자를 초과해서는 안 되며 "amq."로 시작해서는 안 됩니다(passive 매개변수가 true인 경우 제외).
• ConsumerTag: consumer의 이름이며 고유해야 합니다. 설정되지 않으면 서버가 새로 생성합니다.
• NoLocal: true이면 소비자가 동일한 채널에 게시된 메시지를 절대 소비하지 않음을 의미합니다.
• NoAck: true인 경우 서버가 전달된 모든 메시지에 대한 확인을 기대하지 않음을 의미합니다.
• Exclusive: true인 경우 다른 소비자가 이 큐에서 메시지를 소비하는 것을 방지합니다.
• NoWait: true인 경우 서버는 클라이언트에게 확인 응답을 보내지 않습니다.
• Arguments: 사용자 지정 인수를 포함하는 문자열입니다. 값은 json 문자열로 전달되어야 합니다. 예: {"x-dead-letter-exchange":"my-dlx"}.

 

메시지는 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;

ConsumeEx 메서드를 호출하기만 하면 동기 호출을 수행할 수 있으며, 이 메서드는 Consumer가 생성되었으면 true를, 서버로부터 확인이 도착하지 않았으면 false를 반환합니다.

 

Cancel Consume

이 메서드는 기존 consumer queue를 Cancel하는 데 사용됩니다.

 

메서드에는 다음 인수가 있습니다:

 

• ChannelName: 채널의 이름입니다(이 메서드를 호출하기 전에 열려 있어야 함).
• ConsumerTag: 소비자의 이름입니다.
• NoWait: true인 경우 서버는 클라이언트에게 확인 응답을 보내지 않습니다.

 

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

CancelConsumeEx 메서드를 호출하기만 하면 동기 호출을 수행할 수 있으며, 이 메서드는 Consumer가 취소되면 true를, 서버로부터 확인이 도착하지 않으면 false를 반환합니다.