JMS Trigger

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

AnteriorEvent Trigger PróximoKafka Trigger

Atualizado há 12 meses

Este trigger precisa de uma infraestrutura dedicada. Por questões de segurança, é necessário entrar em contato com a nossa Equipe de Suporte para obter a liberação.

Digamos que você queira utilizar um trigger para realizar a subscrição em uma fila de mensagens. Ao usar o JMS Trigger, você consegue disparar um pipeline que habilita o consumo de uma mensagem por vez.

Commit com garantia de entrega

Com a propriedade Auto Commit desabilitada, é possível dar o ack da mensagem somente após a execução bem sucedida do pipeline. Para o broker IBM MQ, é necessário manter esse campo sempre habilitado, pois não é suportado controlar o ack ou o reject da mensagem.

Filas suportadas e parâmetros de configuração

As filas suportadas são:

Oracle Advanced Queue
Tibco EMS
SQS
IBM MQ

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

Parâmetro

Descrição

Valor padrão

Tipo de dado

Dependendo da fila, parâmetros diferentes podem ser acessados:

Oracle AQ

Tibco EMS

SQS

Claro, aqui está a tabela organizada conforme solicitado:

O Visibility Timeout no Broker SQS deve ter um valor maior ou igual que o timeout do pipeline. Isso é necessário, porque o Broker SQS é um sistema distribuído e não remove a mensagem após o seu consumo, já que não há garantia de que ela foi realmente consumida.

Se o Visibility Timeout não é configurado dentro das condições mencionadas, pode ocorrer o reenvio de uma mensagem em processamento. O Broker SQS envia a mensagem novamente caso ela não receba ACK ou REJECT dentro do tempo configurado em Visibility Timeout. Para mais informações, veja a documentação externa.

IBM MQ

Ainda não há suporte para autenticação usando TLS.

JMS Trigger em ação

Se você deseja disparar o trigger, será necessário publicar o pipeline. Veja como realizar o deploy:

Clique em Run, localizado na parte superior da tela.
Selecione o ambiente, que pode ser test ou prod.
Clique em Criar uma nova implantação.
Selecione o pipeline com a sua versão e capacidade.
Clique em Confirmar.

Quando for disparado, o pipeline receberá um payload similar ao seguinte:

{  
    "data":"mensagem"
}

data: conteúdo da mensagem recebida.

O JMS Trigger suporta o consumo de mensagens de forma paralela - o número de consumers configurado na hora do deploy de um pipeline será exatamente o mesmo para a fila/tópico JMS.

Portanto, se forem configurados 10 consumers no deploy, 10 consumers serão criados de tópico/fila JMS.

Isso aumenta o throughput de consumo das mensagens, além de permitir ao usuário ter controle de quantos consumidores simultâneos ele poderá criar.

Antes havia apenas um consumer por trigger.

Caso você realize o deploy de um pipeline com o trigger JMS atrelado a um tópico, é preciso configurar apenas 1 consumer na hora de realizar o deploy.