Über die Message
Broker-Java™-API kann eine Musterinstanz geändert werden, um ESQL-Module zu erstellen. Anschließend
können Sie die ESQL-Module Knoten zuordnen, die ESQL verwenden. Wenn Sie beispielsweise einen
Compute-Knoten erstellen, können Sie über die Message
Broker-Java-API ein ESQL-Modul erstellen und dieses anschließend dem Knoten zuordnen.
ESQL wird beispielsweise von
Compute,
Datenbank-,
DatabaseInput- und
Filter-Knoten verwendet. Wenn Sie ein nicht
standardmäßiges Brokerschema verwenden, müssen Sie das Schema mit der Methode
setBrokerSchema() festlegen.
- Das folgende Beispiel zeigt, wie ein ESQL-Modul im Schema mqsi erstellt
wird. Anschließend wird das Modul mit der Methode
setComputeExpression() einem neuen
Compute-Knoten zugeordnet:
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);
- Das folgende Beispiel zeigt, wie ein ESQL-Modul im Standardschema erstellt wird. Die Methode
setBrokerSchema() ist nicht erforderlich.
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);
- Das folgende Beispiel zeigt, wie ein ESQL-Modul innerhalb einer ESQL-Datei mithilfe der
Methode getEsqlModules() erkannt wird.
Dann können Sie dieses ESQL-Modul mit der Methode
setComputeExpression() zur Festlegung des Rechenausdrucks eines
Compute-Knotens verwenden.
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);