Use o API Java™ do Message Broker para modificar uma instância padrão para criar módulos ESQL. Você pode então associar os
módulos ESQL aos nós que usam ESQL. Por exemplo, se você criar um nó Compute, poderá usar API Java do Message Broker para criar um módulo ESQL e depois associar esse módulo ao nó.
Os
exemplos de nós que usam ESQL são Compute,
Banco de Dados,
DatabaseInput e
Filter. Se estiver usando um esquema do broker não padrão, deverá configurar o esquema usando o método setBrokerSchema().
- O exemplo a seguir mostra como criar um módulo ESQL no esquema
mqsi. O módulo então é designado a um novo nó
Compute usando o método
setComputeExpression():
MessageFlow mf1 = patternInstanceManager.getMessageFlow("MyFlowProject", "main.msgflow");
ESQLModule module = new ESQLModule();
module.setBrokerSchema("mqsi");
module.setEsqlMain("MyESQLMain");
ComputeNode compNode = new ComputeNode();
compNode.setNodeName("My Compute Node");
compNode.setComputeExpression(module);
mf1.addNode(compNode);
- O exemplo a seguir mostra como criar um módulo ESQL no esquema padrão. O método setBrokerSchema()
não é obrigatório.
MessageFlow mf1 = patternInstanceManager.getMessageFlow("MyFlowProject", "main.msgflow");
ESQLModule module = new ESQLModule();
module.setEsqlMain("MyESQLMain");
ComputeNode compNode = new ComputeNode();
compNode.setNodeName("My Compute Node");
compNode.setComputeExpression(module);
mf1.addNode(compNode);
- O exemplo a seguir mostra como descobrir um módulo ESQL em um arquivo ESQL usando
o método getEsqlModules().
Você pode então usar o módulo ESQL para
configurar a expressão de cálculo em um nó
Compute usando o método
setComputeExpression().
MessageFlow mf1 = patternInstanceManager.getMessageFlow("MyFlowProject", "main.msgflow");
File esql = new File("FileBatchProcessingSample_Branch.esql");
ESQLFile esqlFile = new ESQLFile(esql);
Vector<ESQLModule> esqlModules = esqlFile.getEsqlModules();
ComputeNode compNode = new ComputeNode();
compNode.setNodeName("My Compute Node");
compNode.setComputeExpression(esqlModules.get(0));
mf1.addNode(compNode);