Pular para o conteúdo principal

RabbitMQ

Visão Geral​

O trigger RabbitMQ expõe a integração como um serviço capaz de consumir menssagens de uma fila RabbitMQ. Caso deseje publicar mensagens em uma fila, utilize o componente técnico RabbitMQ.

Configuração​

Aqui estão os parâmetros gerais para a configuração do componente. Todos os parâmetros de campos de texto aceitam o uso de variáveis.

Informação adicional

O uso de variáveis em parâmetros de campos de texto é feito utilizando a expressão {{var.nome_da_variavel}}. Para saber mais sobre o uso de variáveis na criação de integrações, acesse a seção Canvas de integrações.

Parâmetros​

  • ID do Componente: Obrigatório. Identificador do componente no fluxo de integração.
Informação adicional

Os IDs são únicos por fluxo. Não é possível ter mais de um componente com o mesmo ID.

O ID do Componente não pode conter espaços, deve iniciar com número e pode conter apenas letras sem acentos, números e o caractere _.

  • Nome: Rótulo opcional para identificar o componente visualmente no canvas.
  • Nome da fila: Obrigatório. Nome da fila onde o conector lerá as mensagens
  • Secret Autenticação: Obrigatório. Secret do tipo "Autenticação" que será usada para conexão com Rabbit. Deve ser cadastrada no Dhuo, na seção "Secrets"
  • Host: Obrigatório. IP ou hostame do servidor Rabbit
  • Porta: Obrigatório. Porta do Rabbit
  • Habilitar Protocolo SSL/TLS: Habilita o TLS na conexão
  • Virtual Host: Obrigatório. Virtual Host do Rabbit
  • Retentativas: Obrigatório. Indica se haverá reprocessamento da mensagem em caso de erro. Opções: Não, Intervalos fixos, Intervalos variados.
    • Não: Sem retentativas. Não reenvia o processamento do fluxo de Integração.
    • Intervalos fixos: Reenvia o processamento mantendo o mesmo intervalo de tempo. Necessário informar o número de retentativas e o intervalo entre elas.
    • Intervalos variados: Reenvia o processamento com intervalos de tempo diferentes. Necessário informar
  • Número de retentativas: Quantidade máxima de retentativas. Disponível se "Retentatiavas" for "Intervalos fixos".
  • Intervalos fixos: Intervalo entre cada retentativa.
  • Intervalos variados: Intervalos de retentativas feitas, divididas por virgula. Exemplo: 10, 20 30 - Serão feitas 3 retentativas, a primeira em 10ms, a segunda em 20ms e a terceira em 30ms.
Informação adicional

Caso o número de retentativas acabe, a mensagem é movida para a fila de erro

Sempre que um trigger rabbit se conecta no servidor configurado, 3 filas são criadas:

  • Fila de consumo normal, com o nome informado no campo "Nome da fila"
  • Fila de retentativa, com o nome rt_nome_da_fila
  • Fila de erro, com o nome dlx_nome_da_fila

Saída​

Após a execução da etapa trigger, uma estrutura chave-valor será gerada com os dados de saída. Os dados podem ser acessados pelo contexto de execução em outros componentes em etapas posteriores do fluxo a partir da sintaxe .atributo_da_estrutura, onde:

  • atributo_da_estrutura: atributo retornado na estrutura chave-valor de saída da execução da etapa trigger
Atenção!

Caso ocorra algum erro durante a execução da etapa trigger, a estrutura chave-valor de saída não é gerada.

Aqui estão os atributos gerais da estrutura de saída do trigger:

  • msgID: Identificador único da requisição, gerado automaticamente pelo DHuO. Esse comportamento pode ser sobrescrito e um valor pré definido poder ser atribuído ao campo msgID caso a requisição recebida contenha o header MessageId.
  • inputHeader: Relação de headers recebidos no formato chave-valor (nome do header/valor do header).
  • inputBody: Mensagem consumida.

Exemplo:

{
  "inputHeader": {
    "Authorization": "Basic XXXXX",
    "Messageid": "70B87A08474E4F8AA38D4A51",
  },
  "inputBody": {
    "user": "John Doe",
    "email": "john.doe@dhuo.io"
  },
  "msgID": "70B87A08474E4F8AA38D4A51"
}