As etapas descritas neste tópico assumem que você esteja unindo:
- Um intermediário WebSphere Message Broker denominado WBRK_BROKER.Quando esse intermediário foi criado,
o mesmo nome foi especificado para o gerenciador de filas.
- Uma rede de intermediários WebSphere MQ Publish/Subscribe com um intermediário raiz, MQPS_ROOT_BROKER, e dois intermediários folha, MQPS_BROKER1 e MQPS_BROKER2.
Substitua os nomes nestes exemplos pelos de seus intermediários sempre que eles forem
utilizados.
Todos os comandos mostrados devem ser emitidos no sistema no qual o recurso
apropriado está definido. Os comandos do WebSphere MQ (por exemplo, o comando para definir uma
fila) são mostrados no formato MQSC. Para obter informações adicionais sobre comandos do WebSphere MQ,
consulte a documentação do WebSphere MQ.
As etapas a seguir descrevem o que você deve fazer para incluir, como um nó pai
em sua rede de intermediários WebSphere MQ Publish/Subscribe, um intermediário WebSphere Message Broker já criado.
Isso é mostrado no diagrama a seguir: O
intermediário
SAMPLE_BROKER do
WebSphere Message Broker une-se à rede
do
WebSphere MQ Publish/Subscribe como o novo nó-pai
(ou seja, como o pai do nó-pai original
MQPS_ROOT_BROKER).
- Certifique-se de que o grupo de execução padrão do intermediário WebSphere Message Broker esteja implementado com
êxito. Esse grupo de execução é implementado na primeira vez que se implementa um
intermediário WebSphere Message Broker recém-criado.Você pode verificar o status do grupo de execução e do
intermediário na visualização topologia no workbench.
- Defina a fila obrigatória para suportar comunicações do intermediário com
WebSphere MQ Publish/Subscribe vizinhos no gerenciador de fila do intermediário WebSphere Message Broker:
define qlocal(SYSTEM.BROKER.INTER.BROKER.COMMUNICATIONS) noshare
- Pare o intermediário WebSphere Message Broker:
mqsistop SAMPLE_BROKER
- Reinicie o intermediário WebSphere Message Broker:
mqsistart SAMPLE_BROKER
Quando o intermediário WebSphere Message Broker for iniciado novamente, ele será ativado para receber e processar
mensagens na fila interintermediários.
- Crie os recursos requeridos no intermediário WebSphere Message Broker para suportar o
fluxo padrão do WebSphere MQ Publish/Subscribe:
- Crie a fila de fluxos padrão:
define qlocal(SYSTEM.BROKER.DEFAULT.STREAM) noshare
- Crie um message flow para publish/subscribe, seu próprio ou com base no
publish/subscribe message flow fornecido:
- Inicialize o workbench e selecione a visualização designer.
- Faça uma cópia do message flow fornecido e renomeie-o; é preciso importar esse
message flow padrão antes de poder acessá-lo e utilizá-lo.
- Verifique as propriedades dos nós no message flow. É preciso definir a propriedade apropriada da fila
(fluxo) de entrada para o nó MQInput. Verifique se as outras propriedades
dos nós estão definidas corretamente para suas necessidades.
- Finalmente, implemente o message flow no grupo de execução padrão do intermediário
SAMPLE_BROKER.
Detalhes completos sobre como concluir essas etapas se encontram na ajuda
on-line para o workbench.
- Se você estiver utilizando fluxos adicionais na rede WebSphere MQ Publish/Subscribe, também precisará
ativar esses fluxos no intermediário WebSphere Message Broker. Embora o intermediário WebSphere Message Broker seja capaz de
suportar todos os fluxos de seus vizinhos WebSphere MQ Publish/Subscribe, somente é necessário definir filas
e definir e implementar message flows para os fluxos pedidos por clientes assinantes
WebSphere Message Broker.
- Crie uma fila local no gerenciador de filas do intermediário WebSphere Message Broker para
cada fluxo no qual as mensagens serão processadas. Por exemplo:
define qlocal(STREAM.X) noshare
- Crie e implemente um message flow para ler e processar as mensagens do WebSphere MQ Publish/Subscribe que
são enviadas a cada fila de fluxo (publicação).
Você pode utilizar
o publish/subscribe message flow fornecido como
a base para cada novo message flow. Cada nó MQInput que representa um fluxo não padrão
deve ter a propriedade implicitStreamNaming definida.
- Insira o seguinte comando do WebSphere MQ Publish/Subscribe em relação ao intermediário que
é o intermediário WebSphere MQ Publish/Subscribe pai atual, para finalizar suas atividades:
endmqbrk -c -m MQPS_ROOT_BROKER
Isso solicita um encerramento controlado (-c). Quando o encerramento
concluir, o intermediário pode ser iniciado novamente. Você pode pedir um encerramento imediato,
especificando -i em vez de -c, se precisar forçar
a conclusão desse encerramento.
- Certifique-se de que a conexão do WebSphere MQ entre os dois intermediários esteja ativa;
é preciso iniciar os listeners para os canais receptores e, em seguida,
iniciar os canais emissores.
- Insira o seguinte comando do WebSphere MQ Publish/Subscribe em relação ao intermediário
WebSphere MQ Publish/Subscribe pai atual para iniciá-lo novamente:
strmqbrk -m MQPS_ROOT_BROKER -p SAMPLE_BROKER
Se o gerenciador de filas associado ao intermediário WebSphere Message Broker SAMPLE_BROKER não tiver sido
criado com o mesmo nome do intermediário, é preciso especificar o nome do gerenciador
de filas aqui após o sinalizador -p, não o nome do intermediário.
- Verifique o êxito da integração:
mqsilistmqpubsub SAMPLE_BROKER
Se o intermediário
WebSphere Message Broker foi
integrado com êxito à rede
WebSphere MQ Publish/Subscribe,
você verá uma resposta semelhante à seguinte:
BIP8090I: O WebSphere MQ Publish/Subscribe vizinho SAMPLE_BROKER
está ativo
BIP8091I: Stream comum SYSTEM.BROKER.DEFAULT.STREAM
BIP8091I: Stream comum STREAM.X