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.

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 ] )

Parâmetros

Propriedades

• tAMQP:ChannelNumber

• tAMQP:Body

• tAMQP:ConsumeTimeout

• tAMQP:QueueName

Métodos

...

tAMQP:QueueDeclare

...

tAMQP:BasicPublish

...

tAMQP:BasicConsume

Retorno

Exemplos

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

Propriedades

tAmqp:ChannelNumber

Indica qual canal esta sendo usado para a fila atual

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 com o AMQP

Métodos

tAmqp:QueueDeclare

Cria uma nova fila no AMQP Server.

Sintaxe

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

Parâmetros

Exemplos

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

tAmqp:BasicConsume

Resgata uma mensagem no AMQP Server.

Sintaxe

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

Parâmetros

Exemplos

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

tAmqp:BasicPublish

Envia uma mensagem para o AMQP Server.

Sintaxe

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

Parâmetros

Exemplos

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

tAmqp:BasicQos

Seta para a conexão atual parametros QoS(quality of service)

Sintaxe

BasicQos( < cprefetchSize >, < cprefetchCount >, < bglobal > )

Parâmetros

Exemplos

  oRecv:BasicQos(cprefetchSize, cprefetchCount, bglobal)

tAmqp:CorrelationID

Indica qual a informação de correlação da mensagem recebida

Sintaxe

CorrelationID()

Exemplos

  oRecv:CorrelationID()

tAmqp:Error

Descreve o erro da ultima operação realizada

Sintaxe

Error()

Exemplos

  oRecv:Error()

tAmqp:QueueName

Indica 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

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

Sintaxe

Status()

Exemplos

  oRecv:Status()

...