...
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.
| Informações | ||||
|---|---|---|---|---|
| ||||
|
...
| Bloco de código | ||
|---|---|---|
| ||
tAmqp():New( < uParam1 >, [ uParam2 ], [ uParam3 ], [ uParam4 ], [ uParam5 ], [ uParam6 ]) |
Nome | Tipo | Descrição | Obrigatório | Referência |
|---|---|---|---|---|
uParam1 | caractere | Endereço do AMQP Server | X | |
uParam2 | numérico | Porta do AMQP Server | ||
uParam3 | caractere | Usuário para logar na fila do AMQP Server | ||
uParam4 | caractere | Senha para logar na fila do AMQP Server | ||
uParam5 | caractere | Canal da comunicação com o AMQP Server | ||
uParam6 | caractere | Virtual Host (vhost) no servidor AMQP (padrão: "/") |
Nome | Tipo | Descrição |
|---|---|---|
oObj | objeto | Nova instância da classe tAmqp |
"/")| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
Local oClient := tAmqp():New("localhost",5672,"guest","guest",1)
|
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
Local oClient := tAmqp():New("localhost", 5672, "guest", "guest", 1, "meu_vhost") |
| Nota |
|---|
A funcionalidade de VHosts está disponível a partir da versão 24.3.0.6 do Application Server. |
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.
Tipo | Valor Padrão | Somente Leitura |
|---|---|---|
numérico | N/A | N |
...
Conteudo da mensagem recebida após uma solicitação ao server AMQP via BasicConsume().
Tipo | Valor Padrão | Somente Leitura |
|---|---|---|
caractere | "" | N |
...
Indica qual o timeout atual que esta sendo usado para a comunicação com o AMQPde um consumidor de uma exchange.
Tipo | Valor Padrão | Somente Leitura |
|---|---|---|
numérico | 5 | N |
...
| Bloco de código | ||
|---|---|---|
| ||
QueueDeclare( [ cFila ], [ bisDurable ], [ bisExclusive ], [ bisAutodelete ], [bisPassive] ) |
Nome | Tipo | Descrição | Obrigatório | Referência |
|---|---|---|---|---|
cFila | caractere | Indica o nome da fila onde será criada. | ||
bisDurable | lógicoPropriedade | da fila bisDurable (TODO DOC)Indica que as mensagens serão guardadas mesmo se o servidor for reiniciado ou desligado, mantendo o estado da fila será mantido. Caso seja falso, as mensagens não serão recriadas caso o servidor seja reiniciado ou desligado. | ||
bisExclusive | lógicoPropriedade | da fila bisExclusive (TODO DOC)Indica que a fila será exclusiva a um único par producer/consumer. | ||
bisAutodelete | lógicoPropriedade da fila bisAutodelete (TODO DOC) | Indica que, ao termino do producer enviar com sucesso a mensagem até o producer, ele irá se deletar. | ||
| bisPassive | lógico | Indica que a função irá apenas verificar se existe uma fila com o nome indicado no AMQP Server, caso exista poderá ser verificar com "Status()", caso não exista não sera criado uma. |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oSender:QueueDeclare(cFila,bisDurable,bisExclusive,bisAutodelete ) |
...
| Bloco de código | ||
|---|---|---|
| ||
QueueDeclareExchangeDeclare( [ cexchange ], [ ctype ], [ bisExclusive bisPassive ], [ bisDurable ], [ bisAutodelete ] ) |
Nome | Tipo | Descrição | Obrigatório | Referência | |||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
cexchange | caractere | Indica o nome da exchange | X | ||||||||||
ctype | carectere | Indica o tipo da fila (fanout, direct, topic). * | X | ||||||||||
bpassivebisPassive | lógico | Indica bpassive(TODO DOC). | bburable | lógico | Indica bburable (TODO DOC). | bauto_delete | lógico | Indica binternal(TODO DOC). | binternal | lógico | Indica binternal(TODO DOC)que a função irá apenas verificar se existe uma exchange com o nome indicado no AMQP Server, caso exista poderá ser verificar com "Status()", caso não exista não sera criado uma. | ||
| bisDurable | lógico | Indica que as mensagens serão guardadas mesmo se o servidor for reiniciado ou desligado, mantendo o estado da fila será mantido. Caso seja falso, as mensagens não serão recriadas caso o servidor seja reiniciado ou desligado. | |||||||||||
| bisAutodelete | lógico | Indica que a mensagem irá automaticamente ser deletada na primeira tentativa de resgate pelo consumer. |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oSender:QueueDeclareExchangeDeclare(cFilacexchange,bisDurable,bisExclusive,bisAutodelete )"fanout",.F.,.F. ) |
Resgata uma mensagem no AMQP Server.
...
Nome | Tipo | Descrição | Obrigatório | Referência |
|---|---|---|---|---|
cFila | caractere | Indica o nome da fila onde será resgatada. | X | |
bAck | lógico | Indica se o consumo irá ser autoackautomaticamente se marcar como entregue, caso contrario, o consumer deverá indicar que a mensagem foi entregue com o método :BasicAck(). | X | |
bWaitingEvent | lógico | Ignora o timeout e se fica aguardando por uma nova mensagem na fila(no maximo por 30 segundos). | X |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicConsume("test_queue", bAck, bWaitingEvent)
|
...
| Bloco de código | ||
|---|---|---|
| ||
QueueBind( < cExchangecQueue >, < cQueuecExchange >, <[ croutingkey >] ) |
Nome | Tipo | Descrição | Obrigatório | Referência |
|---|---|---|---|---|
cExchangecQueue | caractere | Indica o nome da exchangefila. | X | |
cQueuecExchange | caractere | Indica o nome da filaexchange. | X | |
croutingkey | caractereIndica | o routingkey (TODO)Determina um endereço virtual que o exchange pode usar para encaminhar a mensagem para a fila. |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicConsume("test_queue", bAck, bWaitingEvent) |
...
| Bloco de código | ||
|---|---|---|
| ||
BasicPublish( < cExchange >, < cFilacRoutingKey >, [ nPERSISTENT ], [ cMsg ], [ correlationID ], [ ReplyTo ] ) |
...
Nome | Tipo | Descrição | Obrigatório | Referência |
|---|---|---|---|---|
cExchange | caractere | Indica o nome da exchage onde será enviada a mensagem. | X | |
cFilacRoutingKey | caractere | Indica o nome da fila a classificação de onde será enviada a mensagem (fila, rota, etc.) na exchange. | X | |
nPERSISTENT | lógico | Indica que a requisição será persistente. | ||
cMsg | caractere | Informa a mensagem a ser postada. | ||
correlationID | caractere | Id de correlação | ||
ReplyTo | caractere | Fila para resposta dessa mensagem |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicPublish("test_exchange", "test_queue", AMQP_PERSISTENT, "Hello World!" )
|
Seta 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 parametros QoS(quality of service)um limite dessas mensagens a serem processadas (unacknowledged) pelo consumer.
| Bloco de código | ||
|---|---|---|
| ||
BasicQos( < nprefetchSize >, < nprefetchCount >, < bglobal > ) |
...
Nome | Tipo | Descrição | Obrigatório | Referência |
|---|---|---|---|---|
nprefetchSize | numérico | Indica cprefetchSize (TODO)o limite do tamanho das mensagens que poderão ficar em aguardo na atual exchange. | X | |
nprefetchCount | numérico | Indica cprefetchCount (TODO)o numero de mensagens que poderão ficar em aguardo na atual exchange. | X | |
bglobal | lógico | Indica bglobal (TODO)se a configuração atual será global ou não. | X |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicQos(cprefetchSize, cprefetchCount, bglobal) |
...
| Bloco de código | ||
|---|---|---|
| ||
BasicAck( < ctag>cDeliverytag>, < cmultiple>bMultiple>) |
Nome | Tipo | Descrição | Obrigatório | Referência |
|---|---|---|---|---|
ctagcDeliverytag | caractere | Indica ctag (TODO)o nome da tag da(s) mensagem(s) que será marcadada como Ack(recebidas). | X | |
cmultiplebMultiple | caracterelógico | Indica cmultiple (TODO)que varias mensagens serão setadas como Ack simultaneamente. | X |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicQosBasicAck(cprefetchSizectag, cprefetchCount, bglobalbmultiple) |
Indica qual a informação de correlação "apelido" (correlação) da mensagem recebida
| Bloco de código | ||
|---|---|---|
| ||
CorrelationID() |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:CorrelationID() |
...
| Bloco de código | ||
|---|---|---|
| ||
oRecv:MessageCount() |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:MessageCount() |
...
| Bloco de código | ||
|---|---|---|
| ||
oRecv:ConsumerCount() |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:ConsumerCount() |
...
Descreve o erro da ultima operação realizada.
| Bloco de código | ||
|---|---|---|
| ||
Error() |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:Error() |
...
| Bloco de código | ||
|---|---|---|
| ||
ReplyTo() |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:ReplyTo() |
...
| Bloco de código | ||
|---|---|---|
| ||
Status() |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:Status() |
...
| Bloco de código | ||
|---|---|---|
| ||
Tag() |
| Bloco de código | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:Tag() |
...