Verwenden Sie einen
Collector-Knoten in einem Nachrichtenfluss, um
Nachrichten aus einer oder mehreren Quellen in einer Nachrichtensammlung zu gruppieren.
Sie können
für jede Nachrichtenquelle, die Sie für den Nachrichtenfluss konfigurieren möchten, dynamische
Eingabeterminals für den Collector-Knoten hinzufügen.
Bevor Sie beginnen:
Führen Sie die folgenden Aufgaben aus.
Sie können auch einen Compute-Knoten verwenden, um eine Nachrichtensammlung mithilfe von ESQL zu erstellen. Dies ist sinnvoll, wenn Nachrichten für die Syntaxanalyse in Gruppen zusammengefasst werden müssen oder wenn die Nachrichtensammlung so erstellt werden muss, dass sie eine bestimmte Datenstruktur darstellt, z. B. eine CICS Transaction
Server for z/OS-Kanaldatenstruktur.
Weitere Informationen zur Verwendung von ESQL für die Erstellung einer Nachrichtensammlung finden Sie im Abschnitt Nachrichtensammlung mit ESQL erstellen.
Im folgenden Beispiel wird die Verwendung des
Collector-Knotens für Nachrichtensammlungen erläutert:
Informationen zu Beispielen können nur bei Verwendung des in das WebSphere Message
Broker Toolkit integrierten bzw. online verfügbaren Information Center angezeigt werden. Muster können nur ausgeführt werden, wenn das im
WebSphere Message
Broker Toolkit integrierte Information Center verwendet wird.
So erstellen Sie einen Nachrichtenfluss zur Generierung und Verarbeitung von Nachrichtensammlungen:
- Erstellen Sie einen neuen Nachrichtenfluss.
- Fügen Sie die Empfangsknoten in der Editoransicht hinzu. Die Empfangsknoten empfangen Nachrichten, aus denen Nachrichtensammlungen generiert werden. Sie können einen der integrierten Knoten oder einen benutzerdefinierten Empfangsknoten verwenden. Konfigurieren Sie die Knoten und verbinden Sie sie wie beschrieben.
- Fügen Sie für jede Eingabenachrichtenquelle Ihres Nachrichtenflusses einen Empfangsknoten hinzu (z. B. einen MQInput- und einen JMSInput-Knoten).
- Wählen Sie die Empfangsknoten nacheinander aus, um ihre Eigenschaften in der
Eigenschaftenansicht anzuzeigen.
- Geben Sie die Quelle der Eingabenachrichten für diesen Knoten an.
Geben Sie beispielsweise in der Basiseigenschaft Name der Warteschlange den Namen einer
WebSphere MQ-Warteschlange an, aus der der
MQInput-Knoten Nachrichten abruft.
- Optional: Geben Sie für alle anderen Eigenschaften, die Sie für jeden einzelnen Knoten
konfigurieren möchten, Werte an.
- Fügen Sie den Collector-Knoten in der Editoransicht
hinzu. Der Collector-Knoten empfängt Nachrichten von Empfangsknoten oder anderen Knoten im Nachrichtenfluss. Sie müssen für alle Eingabenachrichtenquellen ein dynamisches Eingabeterminal zum Collector-Knoten hinzufügen, bevor Sie die Empfangsknoten oder vorgeordnete Knoten mit dem Collector-Knoten verbinden können.
Konfigurieren Sie die Knoten und verbinden Sie sie wie beschrieben.
- Fügen Sie Ihrem Nachrichtenfluss einen Collector-Knoten hinzu.
- Klicken Sie mit der rechten Maustaste auf den Collector-Knoten und klicken Sie anschließend auf Add
Input Terminal (Eingabeterminal hinzufügen), um dem Collector-Knoten ein neues dynamisches Eingabeterminal hinzuzufügen. Fügen Sie für alle Eingabequellen, die Sie zu Ihrem Nachrichtenfluss hinzufügen möchten, ein neues Eingabeterminal hinzu. Weitere Informationen zu dynamischen Eingabeterminals finden Sie im Abschnitt Für jede Eingabequelle ein Eingabeterminal zu einem Collector-Knoten hinzufügen.
- Verbinden Sie das Ausgangsterminal jedes Empfangsknotens mit einem anderen dynamischen
Eingabeterminal des Collector-Knotens. Dies ist die einfachste Konfiguration; Sie können zwischen dem Empfangsknoten und dem Collector-Knoten gegebenenfalls weitere Knoten einfügen. Beispiel: Sie möchten die Anforderung zu Prüfzwecken speichern (in einem Datenbank-Knoten) oder der Nachricht eine eindeutige Kennung hinzufügen (in einem Compute-Knoten).
- Fügen Sie Verarbeitungsknoten zum Nachrichtenfluss hinzu. Sie können Nachrichtensammlungen aus einem Collector-Knoten nur mit den folgenden Knoten verarbeiten.
Sie müssen entweder einen Compute- oder einen
JavaCompute-Knoten mit dem
Collector-Knoten in Ihrem Nachrichtenfluss verbinden. Verwenden Sie diese Knoten, um die Nachrichtensammlung zu verarbeiten und andere Nachrichten
weiterzugeben. Sie können ESQL oder XPath verwenden, um zur Verarbeitung auf die Inhalte der
einzelnen Nachrichten in der Nachrichtensammlung zuzugreifen.
So verarbeiten Sie eine Nachrichtensammlung:
- Fügen Sie Ihrem Nachrichtenfluss einen Compute- oder einen JavaCompute-Knoten hinzu.
- Codieren Sie ESQL oder Java™, um einzelne Ausgabenachrichten aus der Nachrichtensammlung zu erstellen.
- Optional: Geben Sie für alle Eigenschaften, die Sie für diesen Verarbeitungsknoten
konfigurieren möchten, Werte an.
- Verbinden Sie das Ausgangsterminal des Verarbeitungsknotens mit dem Eingangsterminal eines Sendeknotens oder eines anderen Verarbeitungsknotens.
- Optional: Fügen Sie weitere Verarbeitungsknoten zum Nachrichtenfluss hinzu.
- Sie können einen oder mehrere Sendeknoten in den Nachrichtenfluss einschließen.
Hierbei kann es sich um einen der integrierten Knoten oder um einen benutzerdefinierten Sendeknoten
handeln.
Sendeknoten können keine Nachrichtensammlungen verarbeiten. Daher ist sicherzustellen, dass der
Sendeknoten mit einem Verarbeitungsknoten verbunden wird, der einzelne Ausgabenachrichten
weitergibt. So konfigurieren Sie einen Sendeknoten:
- Wählen Sie die Sendeknoten nacheinander aus, um ihre Eigenschaften in der Eigenschaftenansicht
anzuzeigen.
- Geben Sie für jeden Knoten die Zieleigenschaften an. Geben Sie beispielsweise in der Basiseigenschaft Warteschlangenname den Namen einer WebSphere MQ-Warteschlange an, an die der MQOutput-Knoten Nachrichten sendet.
- Optional: Geben Sie für alle anderen Eigenschaften, die Sie für jeden einzelnen Knoten
konfigurieren möchten, Werte an.
- Fügen Sie die entsprechende Verarbeitung zur Handhabung von Fehlern von abgelaufenen Nachrichtensammlungen hinzu.
- Optional: Fügen Sie Verarbeitungsknoten zur Handhabung von abgelaufenen Nachrichtensammlungen
zum Nachrichtenfluss hinzu. Verbinden Sie diese Knoten mit dem Expire-Terminal des
Collector-Knotens.
- Optional: Fügen Sie Verarbeitungs- oder Fehlerbehandlungsknoten zur Handhabung von
Ausnahmebedingungen zum Nachrichtenfluss hinzu. Verbinden Sie diese Knoten mit dem Catch-Terminal
des Collector-Knotens.
Falls weiter hinten in einem Collector-Knoten ein Fehler festgestellt wird, gibt der Broker eine Ausnahmebedingung aus. Die Nachrichtensammlung wird an das Catch-Terminal des Collector-Knotens geleitet.
Verbinden Sie das Catch-Terminal mit einer Reihe von Knoten zur Fehlerbehandlung, um Datenverluste
zu vermeiden, und stellen Sie sicher, dass während der Fehlerverarbeitung keine weiteren Ausnahmen
generiert werden. Das Catch-Terminal muss entweder mit einem Compute- oder mit einem JavaCompute-Knoten zur Handhabung der Nachrichtensammlung verbunden werden.
- Drücken Sie die Tastenkombination 'Strg-S', oder klicken Sie im Taskleistenmenü auf (wobei Namen für den Namen dieses Nachrichtenflusses steht), um den Nachrichtenfluss zu speichern und seine Konfiguration auszuwerten.
Wenn Sie steuern möchten, zu welchem Zeitpunkt vollständige Nachrichten weitergegeben werden, müssen Sie zusätzliche Knoten zu Ihrem Nachrichtenfluss hinzufügen.
Der Abschnitt
Steuernachrichten mit dem Collector-Knoten verwenden enthält weitere
Informationen hierzu.