Histórico da Página
...
Bloco de código | ||
---|---|---|
| ||
QueueDeclare( [ cFila ], [ bisDurable ], [ bisExclusive ], [ bisAutodelete ] ) |
Parâmetros
Nome | Tipo | Descrição | Obrigatório | Referência |
---|---|---|---|---|
cFila | caractere | Indica o nome da fila onde será criada . |
bisDurable | lógico | Propriedade da fila bisDurable (TODO DOC). |
bisExclusive |
lógico | Propriedade da fila bisExclusive (TODO DOC). | ||
bisAutodelete | lógico | Propriedade da fila |
bisAutodelete (TODO DOC). |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oSender:QueueDeclare(cFila,bisDurable,bisExclusive,bisAutodelete )
|
tAmqp:ExchangeDeclare
Cria uma nova exchange no AMQP Server.
Sintaxe
Bloco de código | ||
---|---|---|
| ||
QueueDeclare( [ cexchange ], [ ctype ], [ bisExclusive ], [ bisAutodelete ] )
|
Parâmetros
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 | ||||||
bpassive | lógico | Indica bpassive(TODO DOC). | |||||||
bburable | lógico | Indica bburable (TODO DOC). | |||||||
bauto_delete | lógico |
|
| bisAutodelete | lógico | Propriedade da fila bisAutodelete Indica binternal | (TODO DOC). | ||
binternal |
| lógico | Indica binternal(TODO DOC). |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oSender:QueueDeclare(cFila,bisDurable,bisExclusive,bisAutodelete )
|
tAmqp:BasicConsume
Resgata uma mensagem no AMQP Server.
Sintaxe
Bloco de código | ||
---|---|---|
| ||
BasicConsume( < cFila >, < bAck >, < bWaitingEvent > ) |
Parâmetros
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 autoack. | X | |
bWaitingEvent | lógico | Ignora o timeout e se fica aguardando por uma nova mensagem na fila. | X |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
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
Bloco de código | ||
---|---|---|
| ||
QueueBind( < cExchange >, < cQueue >, < croutingkey > )
|
Parâmetros
Nome | Tipo | Descrição | Obrigatório | Referência |
---|---|---|---|---|
cExchange | caractere | Indica o nome da exchange. | X | |
cQueue | caractere | Indica o nome da fila | X | |
croutingkey | caractere | Indica o routingkey (TODO). |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicConsume("test_queue", bAck, bWaitingEvent) |
tAmqp:BasicPublish
Envia uma mensagem para o AMQP Server.
Sintaxe
Bloco de código | ||
---|---|---|
| ||
BasicPublish( < cExchange >, < cFila >, [ nPERSISTENT ], [ cMsg ], [ correlationID ], [ ReplyTo ] ) |
Parâmetros
Nome | Tipo | Descrição | Obrigatório | Referência |
---|---|---|---|---|
cExchange | caractere | Indica o nome da exchage onde será enviada a mensagem . | X | |
cFila | caractere | Indica o nome da fila onde será enviada a mensagem . | X | |
nPERSISTENT | lógico | Indica 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 |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicPublish("test_exchange", "test_queue", AMQP_PERSISTENT, "Hello World!" ) |
...
Seta para a conexão atual parametros QoS(quality of service)
Sintaxe
Bloco de código | ||
---|---|---|
| ||
BasicQos( < cprefetchSizenprefetchSize >, < cprefetchCountnprefetchCount >, < bglobal > ) |
Parâmetros
Nome | Tipo | Descrição | Obrigatório | Referência |
---|---|---|---|---|
cprefetchSizenprefetchSize | numérico | Indica cprefetchSize (TODO) | X | |
cprefetchCountnprefetchCount | numérico | Indica cprefetchCount (TODO) | X | |
bglobal | lógico | Indica bglobal (TODO) | X |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicQos(cprefetchSize, cprefetchCount, bglobal)
|
tAmqp:BasicAck
Indica para a fila que voce recebeu e processou a mensagem com sucesso (acknowledge)
Sintaxe
Bloco de código | ||
---|---|---|
| ||
BasicAck( < ctag>, < cmultiple>)
|
Parâmetros
Nome | Tipo | Descrição | Obrigatório | Referência |
---|---|---|---|---|
ctag | caractere | Indica ctag (TODO) | X | |
cmultiple | caractere | Indica cmultiple (TODO) | X |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:BasicQos(cprefetchSize, cprefetchCount, bglobal) |
...
Indica qual a informação de correlação da mensagem recebida
Sintaxe
Bloco de código | ||
---|---|---|
| ||
CorrelationID() |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:CorrelationID() |
tAmqp:Received
Indica quantas mensagens tem na fila prontas para serem recebidas
Sintaxe
Bloco de código | ||
---|---|---|
| ||
oRecv:Received()
|
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:Received()
|
tAmqp:Error
Descreve o erro da ultima operação realizada
Sintaxe
Bloco de código | ||
---|---|---|
| ||
Error() |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:Error() |
tAmqp:QueueName
Indica Retorna qual o nome da fila atual que esta sendo usado
Sintaxe
Bloco de código | ||
---|---|---|
| ||
QueueName() |
...
Informa qual a deve ser a fila solicitada para a resposta da mensagem recebida
Sintaxe
Bloco de código | ||
---|---|---|
| ||
ReplyTo() |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:ReplyTo() |
tAmqp:Status
Informa Retorna o código de erro da ultima operação realizada
Sintaxe
Bloco de código | ||
---|---|---|
| ||
Status() |
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:Status()
|
tAmqp:Tag
Informa qual tag foi associada a uma fila, se houver
Sintaxe
Bloco de código | ||
---|---|---|
| ||
Tag()
|
Exemplos
Bloco de código | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
oRecv:Tag() |