É possível usar o CMP API para gerenciar brokers e seus
recursos associados a partir de nós JavaCompute em fluxos de mensagens implementados.
Antes de começar
Antes de
iniciar esta etapa, você deve criar um Nó JavaCompute em
um fluxo de mensagens.
Use os métodos e classes do CMP em seu nó JavaCompute para explorar
e gerenciar brokers e outros recursos.
- Crie a classe Java para
o nó em que você deseja incluir métodos do CMP.
- Inclua o arquivo JAR do CMP
install_dir/classes/ConfigManagerProxy.jar no
caminho de construção Java para o
projeto Java associado.
- Inclua o seguinte método estático na classe:
BrokerProxy thisBroker = BrokerProxy.getLocalInstance();
Esse
método retorna uma instância do objeto BrokerProxy para o broker
no qual o fluxo de mensagens (que contém este nó) está implementado.
- Para trabalhar com um grupo de execução nesse broker, inclua o
seguinte método estático em seu código:
ExecutionGroupProxy thisEG = ExecutionGroupProxy.getLocalInstance();
Esse método retorna uma instância do objeto ExecutionGroupProxy
para o grupo de execução no qual o fluxo de mensagens está implementado.
- Se você desejar se conectar a um broker diferente
criado no computador no qual seu nó e fluxo de mensagens estão implementados,
poderá usar uma variante desta classe:
BrokerProxy secondBroker = BrokerProxy.getLocalInstance(string)
Especifique
o nome do broker local alternativo como o valor da variável string.
Seu código pode gerenciar este segundo broker e seus recursos associados,
usando o objeto BrokerProxy retornado por essa chamada.
- Inclua métodos adicionais do CMP em
seu código Java para executar as
operações desejadas para o broker ou grupo de execução,
usando os objetos obtidos em etapas anteriores. É possível seguir a orientação fornecida em
outros tópicos desta seção para obter informações adicionais e exemplos
que mostram como usar métodos do CMP
em aplicativos CMP.
Se você incluir métodos que afetam o fluxo de mensagens
no qual o aplicativo do CMP está em execução,
ele não poderá receber todas as notificações de que estas operações
foram concluídas com êxito. Parada, exclusão e reimplementação
do fluxo de mensagens são exemplos nesta categoria;
considere cuidadosamente as consequências do uso destes métodos.
- Implemente o arquivo JAR e todos os fluxos de mensagens associados
em um arquivo BAR. Não é necessário implementar o arquivo ConfigManagerProxy.jar
no grupo de execução de destino, porque o broker pode acessar estas
classes de forma independente.