O modelo de execução do WebSphere Message Broker é o sistema utilizado para executar
fluxos de mensagens através de uma série de nós.
Quando um grupo de execução é inicializado, as LILs apropriadas são disponibilizadas
para o tempo de execução. O processo de tempo de execução do Grupo de Execução é iniciado e cria um encadeamento de
configuração dedicado. No ambiente de execução do fluxo de mensagens, o fluxo de mensagens
é seguro quanto a encadeamentos. Você pode executar fluxos de
mensagens simultaneamente em muitos encadeamentos, sem precisar
considerar questões de serialização. Os nós definidos pelo usuário que
você implementar não devem comprometer esse modelo de encadeamento. Observe os seguintes
pontos:
- Uma mensagem de entrada enviada a um fluxo de mensagens é processada somente pelo encadeamento
que a recebeu. Nenhuma comutação de encadeamento ou de contexto ocorre durante o processamento
de mensagens
- As estruturas de dados acessadas por fluxos de mensagens são visíveis somente para um único
encadeamento, e essas estruturas de dados existem somente pelo tempo de vida da mensagem que está
sendo processada.
- Uma única instância de um fluxo de mensagens é compartilhada entre todos os encadeamentos
no conjunto de encadeamentos do fluxo de mensagens. Isso está
relacionado com o comportamento de um nó de fluxo de mensagens no
sentido de que ele não tem estado.
- Os requisitos de memória de um Grupo de Execução não são afetados excessivamente
pela execução de fluxos de mensagens em mais encadeamentos do S.O.
- O ambiente de execução do fluxo de mensagens é de forma conceitual similar à programação
por procedimento. Os nós que são inseridos em um fluxo de mensagens são chamadas, como subrotinas,
utilizando uma interface de chamada de função. Contudo, em vez de uma interface "chamada-retorno",
na qual parâmetros são transmitidos na forma de dados de mensagens de entrada,
no WebSphere Message Broker o modelo de execução é chamado de um modelo de "propagação e retorno".
- Um fluxo de mensagens do WebSphere Message Broker é inerentemente seguro quanto a encadeamentos, e os fluxos de mensagens podem
ser executados simultaneamente em mais de um encadeamento.
Se, por exemplo, você estiver utilizando um nó definido pelo usuário para processar mensagens
e também estiver utilizando um analisador definido pelo usuário para analisar as mensagens de entrada,
tanto o nó quanto o analisador conterão funções de implementação. O intermediário
chama essas funções de implementação, ou chamadas de retorno, quando certos eventos ocorrerem.
Quando uma mensagem de entrada é recebida no intermediário nesse nó input, ela
é enviada ao nó definido pelo usuário.
- Para nós C, o intermediário chama a função cniEvaluate
para o nó definido pelo usuário. Consulte cniCreateNodeContext para
obter informações sobre a função cniEvaluate.
- Para nós Java, o intermediário chama o método evaluate
implementado pelo nó definido pelo usuário.
Se o nó quiser consultar a mensagem para decidir
o que fazer com ela, ele chamará uma função utilitária C ou um método Java, conforme apropriado
para a linguagem na qual o nó foi gravado. Em seguida, o intermediário chamará o analisador
definido pelo usuário em uma de suas funções de implementação. Isso instruirá o analisador a
começar a construir a árvore de análise do WebSphere Message Broker. O analisador começa a construir a árvore
chamando funções utilitárias que criam elementos na árvore de análise. O
analisador pode ser chamado várias vezes pelo intermediário, em vez de apenas uma vez.