Criando o Fluxo de Mensagens

O fluxo de mensagem da amostra Aluguel de Vídeo é fornecido, mas se você preferir criar o fluxo de mensagens você mesmo, use as seguintes intruções:

  1. Crie um novo projeto do Message Broker chamado Fluxos de Mensagens de Vídeo. Para obter instruções, consulte Criando um Projeto do Message Broker.
  2. Crie um novo fluxo de mensagens denominado Video_Test. Para obter instruções, consulte Criando um Fluxo de Mensagens.
  3. No editor de Fluxo de Mensagens, inclua e renomeie os nós listados na tabela a seguir. Para obter instruções, consulte Incluindo um nó do fluxo de mensagens na documentação do WebSphere Message Broker.
    Gavetas de Paleta Tipo de Nó Nome de Nó
    WebSphere MQ MQInput VIDEO_XML_IN
    WebSphere MQ MQInput VIDEO_TDS_IN
    WebSphere MQ MQInput VIDEO_CWF_IN
    WebSphere MQ MQOutput VIDEO_OUT
    WebSphere MQ MQOutput VIDEO_FAIL
    Transformação Compute Extract Fields
  4. Conecte os nós conforme listado na tabela a seguir. Para obter instruções, consulte Conectando nós de fluxo de mensagens na documentação do WebSphere Message Broker.
    Para verificar se você conectou os nós corretamente, consulte o diagrama em Sobre o fluxo de mensagens Vídeo.
    Nome de Nó Terminal Conectar a esse Nó
    VIDEO_XML_IN Falha VIDEO_FAIL
    Out Extract Fields
    Catch VIDEO_FAIL
    VIDEO_TDS_IN Falha VIDEO_FAIL
    Out Extract Fields
    Catch VIDEO_FAIL
    VIDEO_CWF_IN Falha VIDEO_FAIL
    Out Extract Fields
    Catch VIDEO_FAIL
    Extract Fields Out VIDEO_OUT
  5. Configure as propriedades do nó conforme listadas na tabela a seguir. Aceite os valores padrão para todas as propriedades, a menos que seja listado um valor alternativo na tabela. Para obter instruções, consulte Configurando um nó do fluxo de mensagens na documentação do WebSphere Message Broker.
    Para os nós VIDEO_XML_IN, VIDEO_TDS_IN e VIDEO_CWF_IN, é necessário configurar a propriedade do identificador do conjunto de mensagens. Todos os conjuntos de mensagens têm um identificador exclusivo. Para localizar o Identificador do conjunto de mensagens que você criou, execute a ação a seguir:
    1. Na visualização Desenvolvimento do Intermediário, expanda a árvore de navegação: Fluxos de Mensagens de Vídeo > Conjunto de Mensagens de Vídeo > messageSet.mset.
    2. Dê um clique duplo em messagetSet.mset para abri-lo.
    3. Seu identificador de conjunto de mensagens exclusivo é exibido no campo ID do Conjunto de Mensagens.
    Nome de Nó Página Propriedade Valor
    VIDEO_XML_IN Básico Nome da fila VIDEO_XML_IN
    Análise de Mensagem de Entrada Domínio de mensagem MRM
    Análise de Mensagem de Entrada Conjunto de Mensagens (Selecione seu identificador exclusivo do conjunto de mensagens)
    Análise de Mensagem de Entrada Tipo de mensagem Cliente
    Análise de Mensagem de Entrada Formato de Mensagem XML1
    VIDEO_TDS_IN Básico Nome da fila VIDEO_TDS_IN
    Análise de Mensagem de Entrada Domínio de mensagem MRM
    Análise de Mensagem de Entrada Conjunto de Mensagens (Selecione seu identificador exclusivo do conjunto de mensagens)
    Análise de Mensagem de Entrada Tipo de mensagem Cliente
    Análise de Mensagem de Entrada Formato de Mensagem TDS1
    VIDEO_CWF_IN Básico Nome da fila VIDEO_CWF_IN
    Análise de Mensagem de Entrada Domínio de mensagem MRM
    Análise de Mensagem de Entrada Conjunto de Mensagens (Selecione seu identificador exclusivo do conjunto de mensagens)
    Análise de Mensagem de Entrada Tipo de mensagem Cliente
    Análise de Mensagem de Entrada Formato de Mensagem CWF1
    VIDEO_FAIL Básico Nome da fila VIDEO_FAIL
    Extract Fields Básico Módulo ESQL Video_Test_Compute
    VIDEO_OUT Básico Nome da fila VIDEO_OUT
  6. No projeto Fluxos de Mensagens de Vídeo, dê um clique duplo no arquivo Video_Test.esql para abri-lo no editor ESQL. Copie e cole os seguintes módulos de código ESQL no arquivo ESQL e salve o arquivo. Para obter mais informações, consulte Desenvolvendo ESQL na documentação do WebSphere Message Broker.
    CREATE COMPUTE MODULE Video_Test_Compute
       CREATE FUNCTION Main() RETURNS BOOLEAN
       BEGIN
          -- Este ESQL extrai alguns dos campos da mensagem de entrada
          -- apenas para demonstrar as referências utilizadas para campos em
          -- espaços de nomes diferentes
    
    	  SET OutputRoot = InputRoot;
          DECLARE addr NAMESPACE 'http://www.ibm.com/AddressDetails';
          DECLARE brw NAMESPACE 'http://www.ibm.com/BorrowedDetails';
          DECLARE I INTEGER;
    
    SET OutputRoot.MRM.Name = InputRoot.MRM.Name;
    SET OutputRoot.MRM.addr:Address = InputBody.addr:Address;
    
    IF InputRoot.MRM.ID ='P' THEN
    SET OutputRoot.MRM.PassportNo = InputBody.PassportNo;
    ELSEIF InputRoot.MRM.ID ='D' THEN SET OutputRoot.MRM.DrivingLicenseNo=InputBody.DrivingLicenseNo; ELSEIF InputRoot.MRM.ID ='C' THEN SET OutputRoot.MRM.CreditCardNo=InputBody.CreditCardNo;
    END IF; SET I=1; WHILE I<= CARDINALITY(InputBody.brw:Borrowed.*[]) DO SET OutputRoot.MRM.brw:Borrowed[I].VideoTitle = InputBody.brw:Borrowed[I].VideoTitle; SET OutputRoot.MRM.brw:Borrowed[I].DueDate=InputBody.brw:Borrowed[I].DueDate + INTERVAL '1' DAY; SET OutputRoot.MRM.brw:Borrowed[I].Cost=InputBody.brw:Borrowed[I].Cost*2; SET I=I+1; END WHILE; SET OutputRoot.MRM.Magazine = InputBody.Magazine; RETURN TRUE; END; END MODULE
  7. Salve o fluxo de mensagens.
Você criou o fluxo de mensagens de Vídeo.

Voltar para o Início da Amostra