A classe tAMQP representa um objeto de comunicação do tipo AMQP (Advanced Message Queuing Protocol) da versão 0.9.1, que se comunica com servidores RabbitMQ. A instancia de uma classe permite a comunicação, envio e recebimento de mensagens através de um servidor AMQP, sendo possível o desenvolvimento de diversos tipos de aplicações, realizando transações ou comunicações padronizadas, de forma assíncrona, indiferente da arquitetura de cada uma delas.

Essa classe foi desenvolvida com base na existente biblioteca RabbitMQ.Client desenvolvida para C# .Net, sendo inclusive possível ser usado como referencia a documentação presente em https://www.rabbitmq.com/tutorials/tutorial-one-dotnet.html, assim como montar o ambiente de um servidor AMQP em https://www.rabbitmq.com/#getstarted. Para qualquer informação sobre os conceitos de tipos de fila e comportamentos de recebimentos e envios de mensagens, favor também consultar esse site.

Exemplos

#define AMQP_AUTODELETE .T.
#define AMQP_EXCLUSIVE .T.
#define AMQP_DURABLE .T.
#define AMQP_PERSISTENT .T.
#define AMQP_AUTOACK .T.
#define fixed_channel_id 1

User Function _sender

Local oSender := tAmqp():New("localhost",5672,"guest","guest",fixed_channel_id)

oSender:QueueDeclare("test_queue", .F.,.F.,AMQP_AUTODELETE )
oSender:BasicPublish("","test_queue", AMQP_PERSISTENT, "hello world!")
u___Receiver()
Freeobj(oSender)
Return



User Function _Receiver


Local oRecv := tAmqp():New("localhost",5672,"guest","guest",fixed_channel_id)
local var

oRecv:QueueDeclare("test_queue", .F.,.F.,AMQP_AUTODELETE)
oRecv:BasicConsume("test_queue", AMQP_AUTOACK, )

var := oRecv:Body
 
Freeobj(oRecv)

Return

Abrangência

17.3.0.x

Hierarquia

• tAMQP

Construtores

Construtor tAmqp:New

Cria um objeto tAMQP com um determinado AMQP Server.

Sintaxe

 tAmqp():New( < uParam1 >, [ uParam2 ], [ uParam3 ], [ uParam4 ], [ uParam5 ], [ uParam6 ])

Parâmetros

Retorno

Exemplos:

1. Conectando ao servidor com vhost padrão ("/")

  Local oClient := tAmqp():New("localhost",5672,"guest","guest",1)

2. Conectando ao servidor com um VHost personalizado

 Local oClient := tAmqp():New("localhost", 5672, "guest", "guest", 1, "meu_vhost")

Propriedades

tAmqp:ChannelNumber

Indica qual canal esta sendo usado para a fila atual. Os canais são "planos privados" dentro da mesma conexão TCP”. Ou seja, é necessária apenas uma instância de conexão na mesma porta, e podendo usar varias "subportas" sendo completamente independente de um canal para o outro.

tAmqp:Body

Conteudo da mensagem recebida após uma solicitação ao server AMQP via BasicConsume().

tAmqp:ConsumeTimeout

Indica qual o timeout atual que esta sendo usado para a comunicação de um consumidor de uma exchange.

Métodos

tAmqp:QueueDeclare

Cria uma nova fila no AMQP Server.

Sintaxe

QueueDeclare( [ cFila ], [ bisDurable ], [ bisExclusive ], [ bisAutodelete ], [bisPassive] )

Parâmetros

Exemplos

  oSender:QueueDeclare(cFila,bisDurable,bisExclusive,bisAutodelete )

tAmqp:ExchangeDeclare

Cria uma nova exchange no AMQP Server.

Sintaxe

ExchangeDeclare( [ cexchange ], [ ctype ], [ bisPassive ], [ bisDurable ], [ bisAutodelete ] )

Parâmetros

Exemplos

  oSender:ExchangeDeclare(cexchange,"fanout",.F.,.F. )

tAmqp:BasicConsume

Resgata uma mensagem no AMQP Server.

Sintaxe

BasicConsume( < cFila >, < bAck >, < bWaitingEvent > )

Parâmetros

Exemplos

  oRecv:BasicConsume("test_queue", bAck, bWaitingEvent)

tAmqp:QueueBind

Liga uma fila a uma exchange para que as mensagens fluam (sujeitas a vários critérios) da exchange (origem) para a fila (destino).

Sintaxe

QueueBind( < cQueue >, < cExchange >, [ croutingkey ] )

Parâmetros

Exemplos

  oRecv:BasicConsume("test_queue", bAck, bWaitingEvent)

tAmqp:BasicPublish

Envia uma mensagem para o AMQP Server.

Sintaxe

BasicPublish( < cExchange >, < cRoutingKey >, [ nPERSISTENT ], [ cMsg ], [ correlationID ], [ ReplyTo ] )

Parâmetros

Exemplos

  oRecv:BasicPublish("test_exchange", "test_queue", AMQP_PERSISTENT, "Hello World!" )

tAmqp:BasicQos

Como as mensagens são enviadas (enviadas) para os clientes de forma assíncrona, geralmente há mais de uma mensagem "em trânsito" em um canal a qualquer momento. Com essa função, seta para a conexão atual um limite dessas mensagens a serem processadas (unacknowledged) pelo consumer. 

Sintaxe

BasicQos( < nprefetchSize >, < nprefetchCount >, < bglobal > )

Parâmetros

Exemplos

  oRecv:BasicQos(cprefetchSize, cprefetchCount, bglobal)

tAmqp:BasicAck

Indica para a fila que voce recebeu e processou a mensagem com sucesso (acknowledge)

Sintaxe

BasicAck( < cDeliverytag>, < bMultiple>)

Parâmetros

Exemplos

  oRecv:BasicAck(ctag, bmultiple)

tAmqp:CorrelationID

Indica qual a "apelido" (correlação) da mensagem recebida

Sintaxe

CorrelationID()

Exemplos

  oRecv:CorrelationID()

tAmqp:MessageCount

Indica quantas mensagens tem na fila prontas para serem recebidas

Sintaxe

oRecv:MessageCount()

Exemplos

  oRecv:MessageCount()

tAmqp:ConsumerCount

Indica quantas consumers existem em uma determinada fila.

Sintaxe

oRecv:ConsumerCount()

Exemplos

  oRecv:ConsumerCount()

tAmqp:Error

Descreve o erro da ultima operação realizada.

Sintaxe

Error()

Exemplos

  oRecv:Error()

tAmqp:QueueName

Retorna qual o nome da fila atual que esta sendo usado

Sintaxe

QueueName()

tAmqp:ReplyTo

Informa qual a deve ser a fila solicitada para a resposta da mensagem recebida

Sintaxe

ReplyTo()

Exemplos

  oRecv:ReplyTo()

tAmqp:Status

Retorna o código de erro da ultima operação realizada

Sintaxe

Status()

Exemplos

  oRecv:Status()

tAmqp:Tag

Informa qual tag foi associada a uma fila, se houver

Sintaxe

Tag()

Exemplos

  oRecv:Tag()