Message System (AMS)

Vantagens de utilizar mensageria (AMS) em fluxos iPaaS

O AMS (Apipass Message System) permite que diferentes etapas de um fluxo iPaaS se comuniquem de forma assíncrona e segura por meio de filas, garantindo maior controle, desempenho e flexibilidade na automação de processos. Abaixo, destacamos os principais benefícios dessa abordagem:

1. Orquestração assíncrona entre fluxos

Permite que um fluxo envie uma mensagem e outro a consuma posteriormente, sem que ambos precisem estar executando ao mesmo tempo. Isso reduz a dependência direta entre etapas e possibilita fluxos mais ágeis e desacoplados.

2. Resiliência e confiabilidade

Se um fluxo estiver temporariamente indisponível, as mensagens permanecem na fila até que possam ser processadas. Isso garante que nenhuma informação seja perdida em caso de falhas momentâneas.

3. Escalabilidade com múltiplos consumidores

É possível configurar múltiplos consumidores concorrentes para uma mesma fila, aumentando a capacidade de processamento e garantindo alta performance em cenários de grande volume.

4. Retentativas automáticas e controle de erro

O AMS permite que mensagens com falhas sejam reprocessadas automaticamente ou movidas para filas de erro (dead-letter), oferecendo maior robustez ao tratamento de exceções.

5. Visibilidade e rastreamento

Mensagens trafegadas pelas filas podem ser monitoradas, auditadas e rastreadas, oferecendo total visibilidade para análise e suporte técnico.

Cenário exemplo

Você deseja tratar dados cadastrais recebidos via rest e enviar para outro fluxo que armazena os dados em um banco de dados de forma assíncrona.

Como enviar uma mensagem para uma fila AMS:

Primeiramente, deve-se criar uma fila no menu: Serviços -> Gerenciamento de Filas (vide seção Painel de Gerenciamento de Filas, logo abaixo).

Com a fila criada, podemos desenvolver o fluxo da seguinte maneira:

Detalhamento dos steps do exemplo:

1. Disparo (Trigger)

• Dispara quando é feita chamada via REST.

2. Trata os dados recebidos (Node)

• Remove dados desnecessários do body recebido, valida os dados (ex.: CPF).

3. Enviar Mensagem (AMS)

• Envia os dados tratados para a fila criada anteriormente e configurada no conector.

Pronto! desta forma, uma mensagem ficará disponível na fila do AMS que poderá ser consumida por outro fluxo cuja trigger AMS esteja configurada para observar a mesma fila.

Como consumir a mensagem em outro fluxo:

Usaremos o seguinte exemplo:

Detalhamento dos steps do exemplo:

1. Disparo (AMS Trigger)

• Dispara quando uma mensagem é encontrada na fila configurada.

2. Persiste os dados (Mongo Insert)

• Insere os dados ja tratados, recebidos no body da trigger no mongoDB.

Simples assim! Agora sempre que uma mensagem chegar na fila configurada, o fluxo será disparado e armazenará os dados.

Painel de Gerenciamento de Filas (AMS)

O painel de Gerenciamento de Filas do AMS permite a visualização e o controle completo das filas utilizadas nos fluxos iPaaS. Abaixo estão as funcionalidades disponíveis:

• Campo de busca: permite localizar rapidamente uma fila específica, digitando parte ou o nome completo.

• Botão Atualizar: atualiza a lista de filas para refletir o estado mais recente (como criação, exclusão ou movimentação de mensagens).

Listagem de filas:

A tabela apresenta todas as filas associadas às credenciais do cliente, com as seguintes colunas:

• Nome: nome da fila, geralmente contendo um identificador específico por cliente ou fluxo.

• Criação: data e hora de criação da fila.

• Mensagens disponíveis: número de mensagens prontas para consumo.

• Mensagens em trânsito: número de mensagens que foram consumidas mas ainda não confirmadas (em processamento).

Ações disponíveis:

Acima da tabela, estão disponíveis as seguintes ações:

• Limpar fila: remove todas as mensagens disponíveis da fila selecionada, sem deletar a fila em si.

• Deletar fila: exclui completamente a fila selecionada.

• Editar fila: permite renomear ou modificar propriedades da fila.

• Enviar e receber mensagem: ferramenta para testar manualmente o envio e o consumo de mensagens na fila selecionada.

• Criar fila: botão para criação de novas filas, vinculadas às credenciais do cliente.