Árvore de páginas

Versões comparadas

Chave

  • Esta linha foi adicionada.
  • Esta linha foi removida.
  • A formatação mudou.

...

Bloco de código
collapsefalse
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

bisExclusive

bisAutodelete (TODO DOC).



Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oSender:QueueDeclare(cFila,bisDurable,bisExclusive,bisAutodelete )

tAmqp:ExchangeDeclare

Cria uma nova exchange no AMQP Server.

Sintaxe

Bloco de código
collapsefalse
QueueDeclare( [ cexchange ], [ ctype ], [ bisExclusive ], [ bisAutodelete ] )

Parâmetros

Propriedade da fila 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


bpassive

lógico

Indica bpassive(TODO DOC).



bburablelógicoIndica bburable (TODO DOC).

bauto_deletelógico

 

 

bisAutodelete

lógico

Indica binternal(TODO DOC).

binternal

 

lógico

Indica binternal(TODO DOC). 



Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oSender:QueueDeclare(cFila,bisDurable,bisExclusive,bisAutodelete )

tAmqp:BasicConsume

Resgata uma mensagem no AMQP Server.

Sintaxe

Bloco de código
collapsefalse
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
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  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
collapsefalse
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
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:BasicConsume("test_queue", bAck, bWaitingEvent)

tAmqp:BasicPublish

Envia uma mensagem para o AMQP Server.

Sintaxe

Bloco de código
collapsefalse
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
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  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
collapsefalse
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
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  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
collapsefalse
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
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:BasicQos(cprefetchSize, cprefetchCount, bglobal)

...

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

Sintaxe

Bloco de código
collapsefalse
CorrelationID()

Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:CorrelationID()

tAmqp:Received

Indica quantas mensagens tem na fila prontas para serem recebidas

Sintaxe

Bloco de código
collapsefalse
oRecv:Received()

Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:Received()

tAmqp:Error

Descreve o erro da ultima operação realizada

Sintaxe

Bloco de código
collapsefalse
Error()

Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:Error()


tAmqp:QueueName

Indica Retorna qual o nome da fila atual que esta sendo usado

Sintaxe

Bloco de código
collapsefalse
QueueName()

...

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

Sintaxe

Bloco de código
collapsefalse
ReplyTo()

Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:ReplyTo()


tAmqp:Status

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

Sintaxe

Bloco de código
collapsefalse
Status()

Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:Status()

tAmqp:Tag

Informa qual tag foi associada a uma fila, se houver

Sintaxe

Bloco de código
collapsefalse
Tag()

Exemplos

Bloco de código
languagecpp
themeEclipse
linenumberstrue
collapsefalse
  oRecv:Tag()