Histórico da Página
...
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 | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oSender:QueueDeclare(cFila,bisDurable,bisExclusive,bisAutodelete ) |
tAmqp:ExchangeDeclare
ria Cria uma nova exchange no AMQP Server.
...
Bloco de código | ||
---|---|---|
| ||
QueueDeclareExchangeDeclare( [ cexchange ], [ ctype ], [ bisPassive ], [ bisDurable ], [ bisAutodelete ] ) |
...
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oSender:ExchangeDeclare(cexchange,"fanout",.F.,.F. )
|
tAmqp:BasicConsume
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á automaticamente 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 |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicConsume("test_queue", bAck, bWaitingEvent) |
...
Bloco de código | ||
---|---|---|
| ||
QueueBind( < cExchangecQueue >, < cQueuecExchange >, [ croutingkey ] ) |
Parâmetros
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 | caractere | Determina um endereço virtual que o exchange pode usar para encaminhar a mensagem para a fila. |
...
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 |
...