WebSphere Message Broker, Versão 8.0.0.5 Sistemas operacionais: AIX, HP-Itanium, Linux, Solaris, Windows, z/OS

Consulte as informações sobre a versão mais recente do produto em IBM Integration Bus, Versão 9.0

Conectando-se a um Broker a partir de um Aplicativo CMP

Conecte um aplicativo que usa o CMP API a um broker para enviar pedidos sobre seu status e seus recursos.

Antes de começar

Antes de iniciar esta etapa, é necessário ter concluído Configurando um Ambiente para Desenvolvimento e Execução de Aplicativos do CMP.

Considere o seguinte programa BrokerRunStateChecker.java. Ele se conecta a um broker em execução no gerenciador de fila padrão do computador local.

import com.ibm.broker.config.proxy.*;

public class BrokerRunStateChecker {

    public static void main(String[] args) {

	    	// The ip address of where the broker is running
  		  	// and the port number of the queue manager listener.
        displayBrokerRunState("localhost", 2414, "");
    }

    public static void displayBrokerRunState(String hostname,
                                             int port,
                                             String qmgr) {
        BrokerProxy b = null;
        try {
            BrokerConnectionParameters bcp =
                new MQBrokerConnectionParameters(hostname, port, qmgr);
            b = BrokerProxy.getInstance(bcp);
            String brokerName = b.getName();
            
            System.out.println("O broker '"+brokerName+
                "' está disponível!");
            b.disconnect();
        } catch (ConfigManagerProxyException ex) {
            System.out.println("O broker NÃO está disponível"+
                " because "+ex);
        }
    }
}

A primeira linha do programa solicita ao Java™ para importar as classes do CMP API, que são fornecidas no pacote com.ibm.broker.config.proxy.

A primeira linha do código dentro do bloco try do método displayBrokerRunState() instancia um objeto BrokerConnectionParameters. Este método é uma interface que indica que as classes de implementação podem fornecer os parâmetros para conexão com um broker.

A classe MQBrokerConnectionParameters implementa essa interface; isso define um conjunto de parâmetros de conexão do WebSphere MQ. O construtor utilizado aqui utiliza três parâmetros:
  1. O nome do host do computador no qual o broker está em execução
  2. A porta na qual o serviço listener do WebSphere MQ para o broker está atendendo
  3. O nome do gerenciador de fila que está associado ao broker

Depois de definir esse objeto, é possível se conectar ao gerenciador de fila que está definido por essas características. A conexão é obtida pelo método do gerador de getInstance() estático que se encontra dentro do bloco try. Quando um identificador válido para o gerenciador de fila é retornado, o aplicativo solicita o nome do broker usando b.getName() e o exibe.

getName() e outros métodos que solicitam informações do broker ficam bloqueados até que as informações sejam fornecidas ou ocorra um tempo limite. Portanto, se o broker não estiver em execução, o aplicativo ficará interrompido por um período. É possível controlar o período de tempo limite usando o método BrokerProxy.setRetryCharacteristics(). Geralmente, o bloqueio ocorre apenas quando um determinado recurso é acessado pela primeira vez em um aplicativo.

Por último, o programa chama o método disconnect(). Este método libera os recursos associados à conexão no CMP e no broker.

Quando um identificador BrokerProxy é retornado pela primeira vez do método getInstance(), o serviço do broker não precisa estar em execução. É apenas quando o aplicativo usa o identificador (chamando getName() neste exemplo) que o aplicativo pode ter a garantia de que uma conexão bidirecional com o broker está ativa.

Avisos | Marcas Registradas | Downloads | Biblioteca | Suporte | Feedback

Copyright IBM Corporation 1999, 2014Copyright IBM Corporation 1999, 2014.

        
        Última atualização:
        
        Última atualização: 2015-02-28 18:31:16


Tópico de TarefaTópico de Tarefa | Versão 8.0.0.5 | be43130_