O RabbitMQ permite a publicação de mensagens em um broker RabbitMQ.
Dê uma olhada nos parâmetros de configuração do componente:
Account: credencial utilizada para autenticação no RabbitMQ.
Hostname: nome do host que executa o RabbitMQ.
Port: porta de conexão do RabbitMQ (padrão: 5672).
Connection Timeout: tempo máximo para conexão ao RabbitMQ.
Virtual Host: nome do grupo lógico dentro do RabbitMQ ao qual se deseja conectar (padrão /).
Exchange Name: nome do exchange definido no RabbitMQ ao qual se deseja enviar mensagens.
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.
Message Body: conteúdo da mensagem a ser enviada.
Routing Key: string representando a chave de relacionamento entre o Exchange e a(s) Fila(s).
Headers: conjunto de entradas "chave": "valor" contendo cabeçalhos que serão enviados na mensagem (campo opcional).
Message Type: string representando o tipo de mensagem (campo opcional).
Message Content Type: string representando o tipo de conteúdo da mensagem (ex.: application/json) (campo opcional).
Message Content Encoding: string representando a codificação do conteúdo (ex.: UTF-8) (campo opcional).
Priority: número indicando a prioridade da mensagem (campo opcional).
Correlation ID: string representando o ID de correlação da mensagem (campo opcional).
Message ID: string representando o ID da mensagem (campo opcional).
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.
Reply To: string representando o endereço de retorno da mensagem (campo opcional).
Message Expiration: número representando o tempo de duração da mensagem em fila (também conhecido como TTL) (campo opcional).
Message Timestamp: número representando o timestamp da mensagem (campo opcional).
Application Name: string representando o nome da aplicação (campo opcional).
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".
Wait for a Publish Acknowledgement: se a opção estiver ativada, o componente aguardará por uma confirmação de publicação da mensagem; do contrário, o componente enviará a mensagem e não aguardará confirmação.
Publisher Acknowledgement Timeout: tempo máximo que o componente aguardará por uma confirmação de publicação da mensagem.
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).
IMPORTANTE: 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>IMPORTANTE: 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 componente 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 componente a partir do Exchange e do Routing Key. O Exchange possui um bind com um tópico ou uma fila e direciona a mensagem a partir do 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"
}