Listening-Service-Architektur für private Jitterbit-Agenten
Einführung
Der Abhördienst kann einen Operation ausführen, wenn ein Ereignis an einem Endpoint auftritt. Funktioniert nur mit unterstützten Konnektoren und Aktivitäten und nur bei privaten Agentengruppen.
Architekturdiagramm
Dieses Diagramm zeigt, wie sich eine Ereignismeldung durch das System bewegt, wenn ein einzelner privater Agent verwendet wird:
-
Ein Operation, der einen Connector enthält, der mit einer Ereignis-Abhöraktivität konfiguriert ist, wird bereitgestellt und zum Abhören aktiviert. Eine Abhöraktivität kann in vielen Vorgängen und Projekten verwendet werden, um dasselbe Ereignis zu empfangen, es aber unterschiedlich zu verarbeiten.
-
Der Listening-Dienst innerhalb des Agenten startet einen Listener für diesen Operation.
-
Der Listener beginnt aktiv mit dem Abhören von Ereignisbenachrichtigungen vom Endpoint.
-
Wenn am Endpoint ein Ereignis eintritt, veröffentlicht dieser eine Ereignisbenachrichtigung, die von seinen Abonnenten empfangen werden kann.
-
Der Listener nimmt die Ereignisbenachrichtigungsnachricht auf.
-
Wenn sich in der Agentengruppe ein Agent befindet, leitet der Listener die Ereignismeldung an den Operation weiter. Wenn die Agentengruppe die Mindestanzahl enthält, um die volle Listening-Service-Kapazität zu ermöglichen, wird die Ereignismeldung an den Agenten mit der geringsten Arbeitslast weitergeleitet.
-
Beim Empfang der Ereignisbenachrichtigung löst die Operation eine nachlegende Operation aus.
Wenn der Listening-Dienst deaktiviert ist, kommunizieren Agenten in einer Agentengruppe direkt mit Harmony. Wenn er aktiviert ist und eine Mindestanzahl von Agentenknoten aktiv ist, kommunizieren Agenten miteinander, um einen Cluster zu bilden. Der erste registrierte Agent wird zum Clusterleiter ernannt. Der Leiter ist für den Empfang von Nachrichten und deren Verteilung an Clustermitglieder zur Verarbeitung verantwortlich. Der Clusterleiter verteilt die Last auf alle Agenten und stellt sicher, dass nicht zwei Agenten dieselbe Nachricht verarbeiten.