JBoss Fuse - Apache AMQ

Neste capítulo, conheceremos o ActiveMQ e como ele atua como um intermediário de mensagens para permitir que os aplicativos se comuniquem entre si.

O que é AMQ?

ActiveMQ é um agente de mensagens de código aberto escrito em Java. É totalmente compatível com os padrões JMS 1.1.

JMS é uma especificação que permite o desenvolvimento de sistema baseado em mensagem. O ActiveMQ atua como um intermediário de mensagens que fica entre os aplicativos e permite que eles se comuniquem de maneira assíncrona e confiável.

Tipos de mensagens

Existem dois tipos de opções de mensagens explicadas abaixo para uma melhor compreensão.

Ponto a ponto

Nesse tipo de comunicação, o broker envia mensagens para apenas um consumidor, enquanto os demais consumidores aguardam até receberem as mensagens do broker. Nenhum consumidor receberá a mesma mensagem.

Se não houver consumidores, o Broker reterá as mensagens até chegar a um consumidor. Este tipo de comunicação também é chamado deQueue based communicationonde o produtor envia mensagens para uma fila e apenas um consumidor recebe uma mensagem da fila. Se houver mais de um consumidor, eles podem receber a próxima mensagem, mas não receberão a mesma mensagem do outro consumidor.

Publicar / Assinar

Nesse tipo de comunicação, o Broker envia a mesma cópia das mensagens para todos os consumidores ativos. Este tipo de comunicação também é conhecido comoTopic based communicationonde o corretor envia a mesma mensagem para todos os consumidores ativos que se inscreveram em um determinado Tópico. Este modelo suporta comunicação unilateral onde nenhuma verificação de mensagens transmitidas é esperada.