Implementar método de subida dos Consumers AMQP

Objetivo

Elaborar o documento técnico que orientará a implementação do canal de comunicação AMQP no EAI 2.0.

Definições Gerais

A primeira versão do documento técnico foi desenvolvido considerando o escopo e restrições listados abaixo.

Escopo e Restrições

• A parametrização do canal de envio (AMQP) deverá ser realizada no cadastro do aplicativo integrado.
• Será utilizada a Exchange padrão para envio e recebimento de mensagens. 
  • A Exchange padrão é do tipo Direct, orientada por RoutingKey (nome da fila).
• Os aplicativos irão consumir, na Exchange padrão, a fila com RoutingKey igual seu AppId (padrão [Aplicativo]@[SourceApplication]) para recebimento de mensagens.
• Será utilizado o padrão RPC para a comunicação, viabilizando assim o aguardo da mensagem de resposta, conforme o protocolo de Mensagem Padronizada.
• O serviço de consumo da fila de mensagens será inicializado automaticamente com o servidor de aplicação, de acordo com a parametrização.
• O protocolo AMQP é suportado pelo EAI 2.0 na sua versão 0.9.1

Definições da Regra de Negócio

Configurações

Canal de Envio

A parametrização do canal de envio será realizada a partir do cadastro de aplicativos no EAI 2.0

Image Added

Fila de Recebimento

A parametrização da fila de recebimento será realizada a partir da conjunção do produto com o source application interno da configuração do EAI 2.0 no formato ([Produto]@[SourceApplication])

Image Added

Parametrização de Subida dos Consumidores da fila de Recebimento

A parametrização de subida dos consumidores da fila de recebimento será realizada a partir do arquivo de configuração do servidor de aplicação e será dado através dos parâmetros citados abaixo

AMQPSERVER

<?xml version="1.0"?>
<configuration>
    <appSettings>
        <add key="AMQPServer" value="true" />
    </appSettings>
</configuration>

Indica se o servidor AMQP será habilitado na subida do servidor de aplicação.

Parâmetro do tipo lógico com valor padrão definido como falso.

AMQPSERVERTHREADS

<?xml version="1.0"?>
<configuration>
    <appSettings>
        <add key="AMQPServerThreads" value="3" />
    </appSettings>
</configuration>

Indica a quantidade de threads que serão criadas para o consumo da fila de recebimento.

Parâmetro do tipo inteiro com valor padrão definido como 1.

AMQPSERVERPOOLINGINTERVAL

<?xml version="1.0"?>
<configuration>
    <appSettings>
        <add key="AMQPServerPoolingInterval" value="10" />
    </appSettings>
</configuration>

Indica o período em minutos o qual o servidor AMQP irá realizar a verificação da saúde da conexão dos consumidores de fila e definidos na configuração do canal e caso seja necessário recria as instâncias dos consumidores com suas devidas conexões para que minimizemos o período de perda de conexão.

Parâmetro do tipo inteiro com valor padrão definido como 10.

Protocolo AMQP

O protocolo AMQP é suportado pelo EAI 2.0 na sua versão 0.9.1