Commands | AMQP Get Messages

Getting messages is a Synchronous task, which means that is the client who ask to server is there are messages in the queue. You can read an alternative method to Receive Message Aynchronously.

 

Get Message

The method GetMessage sends a request to the AMQP server asking if there are messages available in a queue. If there are messages these will be dispatched OnAMQPBasicGetOk event and if the queue is empty, the event OnAMQPBasicGetEmpty will be called.

 

The method has the following arguments:

 

• ChannelName: it's the name of the channel (must be open before call this method).
• QueueName: it's the name of the queue, must be no longer of 255 characters and not begin with "amq." (except if passive parameter is true).
• NoWait: if true, the server won't send an acknowledgment to the client.

 

AMQP->GetMessage("channel_name", "queue_name");
 
private void OnAMQPBasicGetOk(TObject *Sender, const string aChannel, 
  const TsgcAMQPFramePayload_Method_BasicGetOk *aGetOk, 
  const TsgcAMQPMessageContent *aContent)
{
  DoLog("#AMQP_basic_GetOk: " + aChannel + " " + IntToStr(aGetOk->MessageCount) + " " + aContent->Body->AsString);
}
 
private void OnAMQPBasicGetEmpty(TObject *Sender, const string aChannel)
{
  DoLog("#AMQP_basic_GetEmpty: " + aChannel);
}

A Synchronous call can be done just calling the method GetMessageEx, this method returns true if the queue has messages available, otherwise the result will be false.