RabbitMQ

Descubra mais sobre o conector RabbitMQ e saiba como utilizá-lo na Digibee Integration Platform.

O RabbitMQ permite a publicação de mensagens em um broker RabbitMQ.

Parâmetros

Dê uma olhada nas opções de configuração do conector. Parâmetros suportados por expressões Double Braces estão marcados com (DB).

Parâmetro Descrição Valor padrão Tipo de dado

Parâmetro	Descrição	Valor padrão	Tipo de dado
SSL/TLS	Ativa o método de autenticação SSL/TLS ao se conectar a um servidor RabbitMQ.	False	Booleano
Account	Conta do tipo Basic necessária para se autenticar utilizando o método basic. Essa opção só está disponível se o parâmetro SSL/TLS for desativado.	N/A	Account
Key Store	Conta do tipo Certificate-chain (no formato PEM) contendo os certificados necessários do cliente para se autenticar utilizando o método SSL/TLS. Essa opção só está disponível se o parâmetro SSL/TLS for ativado.	N/A	Account
Trust Store	Conta do tipo Certificate-chain (no formato PEM) contendo o trust material necessário para se autenticar utilizando o método SSL/TLS. Essa opção só está disponível se o parâmetro SSL/TLS for ativado.	N/A	Account
Hostname Verification	Se ativado, será verificado se o certificado do servidor foi emitido para o hostname ao qual está sendo feita a conexão. Essa opção só está disponível se o parâmetro SSL/TLS for ativado.	False	Booleano
Hostname	Nome do host que executa o RabbitMQ.	N/A	String
Port	Porta de conexão do RabbitMQ (padrão: 5672).	5672	Inteiro
Connection Timeout	Tempo máximo para conexão ao RabbitMQ.	60000	Inteiro
Virtual Host	Nome do grupo lógico dentro do RabbitMQ ao qual se deseja conectar.	/	String
Exchange Name `(DB)`	Nome do exchange definido no RabbitMQ ao qual se deseja enviar mensagens.	N/A	String
Binary Message	Se a opção estiver ativada, a mensagem será considerada binária e o campo Message Body deverá informar uma string contendo a representação base64 do conjunto de bytes a enviar; do contrário, a mensagem será considerada como texto.	False	Booleano
Message Body `(DB)`	Conteúdo da mensagem a ser enviada.	N/A	String
Routing Key	String representando a chave de relacionamento entre o Exchange e a(s) Fila(s).	N/A	String
Headers	Conjunto de entradas chave-valor (key-value) contendo cabeçalhos que serão enviados na mensagem (campo opcional).	N/A	Key-value
Message Type	String representando o tipo de mensagem (campo opcional).	N/A	String
Message Content Type	String representando o tipo de conteúdo da mensagem (ex.: application/json) (campo opcional).	N/A	String
Message Content Encoding	String representando a codificação do conteúdo (ex.: UTF-8) (campo opcional).	N/A	String
Priority	Número indicando a prioridade da mensagem (campo opcional).	N/A	Inteiro
Correlation ID	String representando o ID de correlação da mensagem (campo opcional).	N/A	String
Message ID	String representando o ID da mensagem (campo opcional).	N/A	String
Delivery Mode	Se "Persistent Message", então a mensagem é enviada com a flag persistente e o broker tentará mantê-la em disco assim que possível; se "Transient Message", então o broker tentará manter a mensagem em memória.	Persistent Message	String
Reply To	String representando o endereço de retorno da mensagem (campo opcional).	N/A	String
Message Expiration	Número representando o tempo de duração da mensagem em fila (também conhecido como TTL) (campo opcional).	N/A	Inteiro
Message Timestamp	Número representando o timestamp da mensagem (campo opcional).	N/A	Inteiro
Application Name	String representando o nome da aplicação (campo opcional).	N/A	String
Fail On Error	Se a opção estiver habilitada, a execução do pipeline com erro será interrompida; do contrário, a execução do pipeline continua, mas o resultado vai mostrar um valor falso para a propriedade "success".	False	Booleano
Wait for a Publish Acknowledgement	Se a opção estiver ativada, o conector aguardará por uma confirmação de publicação da mensagem; do contrário, o conector enviará a mensagem e não aguardará confirmação.	False	Booleano
Publisher Acknowledgement Timeout	Tempo máximo que o conector aguardará por uma confirmação de publicação da mensagem.	5000	Inteiro
Mandatory Message	Se a opção estiver ativada, então a mensagem é marcada como obrigatória e um erro será lançado caso ela não possa ser roteada; do contrário, então nenhuma verificação de roteamento será feita (é necessário que a opção "Wait for a Publish Acknowledgement" seja habilitada).	False	Booleano

SSL/TLS

Ativa o método de autenticação SSL/TLS ao se conectar a um servidor RabbitMQ.

False

Booleano

Account

Conta do tipo Basic necessária para se autenticar utilizando o método basic.

Essa opção só está disponível se o parâmetro SSL/TLS for desativado.

N/A

Account

Key Store

Conta do tipo Certificate-chain (no formato PEM) contendo os certificados necessários do cliente para se autenticar utilizando o método SSL/TLS.

Essa opção só está disponível se o parâmetro SSL/TLS for ativado.

N/A

Account

Trust Store

Conta do tipo Certificate-chain (no formato PEM) contendo o trust material necessário para se autenticar utilizando o método SSL/TLS.

Essa opção só está disponível se o parâmetro SSL/TLS for ativado.

N/A

Account

Hostname Verification

Se ativado, será verificado se o certificado do servidor foi emitido para o hostname ao qual está sendo feita a conexão.

Essa opção só está disponível se o parâmetro SSL/TLS for ativado.

False

Booleano

Hostname

Nome do host que executa o RabbitMQ.

N/A

String

Port

Porta de conexão do RabbitMQ (padrão: 5672).

5672

Inteiro

Connection Timeout

Tempo máximo para conexão ao RabbitMQ.

60000

Inteiro

Virtual Host

Nome do grupo lógico dentro do RabbitMQ ao qual se deseja conectar.

String

Exchange Name (DB)

Nome do exchange definido no RabbitMQ ao qual se deseja enviar mensagens.

N/A

String

Binary Message

Se a opção estiver ativada, a mensagem será considerada binária e o campo Message Body deverá informar uma string contendo a representação base64 do conjunto de bytes a enviar; do contrário, a mensagem será considerada como texto.

False

Booleano

Message Body (DB)

Conteúdo da mensagem a ser enviada.

N/A

String

Routing Key

String representando a chave de relacionamento entre o Exchange e a(s) Fila(s).

N/A

String

Headers

Conjunto de entradas chave-valor (key-value) contendo cabeçalhos que serão enviados na mensagem (campo opcional).

N/A

Key-value

Message Type

String representando o tipo de mensagem (campo opcional).

N/A

String

Message Content Type

String representando o tipo de conteúdo da mensagem (ex.: application/json) (campo opcional).

N/A

String

Message Content Encoding

String representando a codificação do conteúdo (ex.: UTF-8) (campo opcional).

N/A

String

Priority

Número indicando a prioridade da mensagem (campo opcional).

N/A

Inteiro

Correlation ID

String representando o ID de correlação da mensagem (campo opcional).

N/A

String

Message ID

String representando o ID da mensagem (campo opcional).

N/A

String

Delivery Mode

Se "Persistent Message", então a mensagem é enviada com a flag persistente e o broker tentará mantê-la em disco assim que possível; se "Transient Message", então o broker tentará manter a mensagem em memória.

Persistent Message

String

Reply To

String representando o endereço de retorno da mensagem (campo opcional).

N/A

String

Message Expiration

Número representando o tempo de duração da mensagem em fila (também conhecido como TTL) (campo opcional).

N/A

Inteiro

Message Timestamp

Número representando o timestamp da mensagem (campo opcional).

N/A

Inteiro

Application Name

String representando o nome da aplicação (campo opcional).

N/A

String

Fail On Error

Se a opção estiver habilitada, a execução do pipeline com erro será interrompida; do contrário, a execução do pipeline continua, mas o resultado vai mostrar um valor falso para a propriedade "success".

False

Booleano

Wait for a Publish Acknowledgement

Se a opção estiver ativada, o conector aguardará por uma confirmação de publicação da mensagem; do contrário, o conector enviará a mensagem e não aguardará confirmação.

False

Booleano

Publisher Acknowledgement Timeout

Tempo máximo que o conector aguardará por uma confirmação de publicação da mensagem.

5000

Inteiro

Mandatory Message

Se a opção estiver ativada, então a mensagem é marcada como obrigatória e um erro será lançado caso ela não possa ser roteada; do contrário, então nenhuma verificação de roteamento será feita (é necessário que a opção "Wait for a Publish Acknowledgement" seja habilitada).

False

Booleano

Todos os parâmetros de configuração opcionais não serão definidos na mensagem caso os seus valores sejam deixados em branco.

Exemplo de resposta de requisição ao RabbitMQ

<MESMA MENSAGEM QUE FOI INFORMADA NA ENTRADA>

O RabbitMQ não altera a mensagem apresentada na sua entrada, exceto em caso de erro.

Exemplo de resposta de requisição ao RabbitMQ contendo erro

{
"success": false,
"message": "Could not publish message to RabbitMQ due to an error",
"error": "java.net.SocketTimeoutException: connect timed out"
}

success: “false” quando a operação falha.
message: mensagem sobre o erro.
exception: informação sobre o tipo de erro ocorrido.

Fluxo de Mensagens

Entrada

O conector aceita qualquer mensagem de entrada, podendo utilizá-la por meio de Double Braces.

Saída

sem erro

<A MESMA MENSAGEM INFORMADA NA ENTRADA>

com erro

{
"success": false,
"message": "Could not publish message to RabbitMQ due to an error",
"error": "java.net.SocketTimeoutException: connect timed out"
}

RabbitMQ em ação

Uma mensagem é sempre enviada através desse conector a partir do Exchange Name e do Routing Key. O exchange possui um bind com um tópico ou uma fila e direciona a mensagem a partir da routing key.

Enviando uma mensagem simples

Mensagem de entrada:

{
"message": "test"
}

Configurações:

Hostname: <RABBITMQ HOSTNAME>
Port: <PORT> (porta padrão: 5672)
Virtual Host: /
Exchange Name: <EXCHANGE NAME>
Binary Message: desabilitado
Message: {{ message.$ }}
Routing key: <ROUTING KEY>
Fail On Error: desabilitado

Resultado:

{
"message": "test"
}

Enviando uma mensagem binária simples

Mensagem de entrada:

{
"message": "ewoJIm1lc3NhZ2UiOiAidGVzdCIKfQo="
}

Configurações:

Hostname: <RABBITMQ HOSTNAME>
Port: <PORT> (porta padrão: 5672)
Virtual Host: /
Exchange Name: <EXCHANGE NAME>
Binary Message: habilitado
Message: {{ message.message }}
Routing key: <ROUTING KEY>
Fail On Error: desabilitado

Resultado:

{
"message": "ewoJIm1lc3NhZ2UiOiAidGVzdCIKfQo="
}

Enviando uma mensagem para uma fila e a resposta será devolvida para uma outra especificada (Direct Reply-To)

Mensagem de entrada:

{
"message": "test"
}

Configurações:

Hostname: <RABBITMQ HOSTNAME>
Port: <PORT> (porta padrão: 5672)
Virtual Host: /
Exchange Name: <EXCHANGE NAME>
Binary Message: desabilitado
Message: {{ message.$ }}
Routing key: <ROUTING KEY>
Reply To: <REPLY TO>
Fail On Error: desabilitado

Resultado:

{
"message": "test"
}

AnteriorKafka PróximoSQS (AWS)

Atualizado há 5 meses