PublishJMS 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-jms-processors-nar
Beschreibung¶
Erzeugt eine JMS-Meldung aus dem Inhalt eines FlowFile und sendet sie als JMS BytesMessage oder TextMessage an ein JMS-Ziel (Warteschlange oder Thema). FlowFile-Attribute werden als JMS-Header und/oder Eigenschaften zu der ausgehenden JMS-Meldung hinzugefügt.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Connection Client ID |
Die Client-ID, die für die Verbindung festgelegt werden soll, sofern angegeben. Für einen dauerhaften, nicht geteilten Verbraucher ist dies obligatorisch, für alle anderen ist es optional. Bei geteilten Verbrauchern ist es in der Regel nicht erwünscht, diese Option zu aktivieren. Weitere Information finden Sie in der JMS-Spezifikation |
Connection Factory Service |
Der Controller Service, der verwendet wird, um Connection Factory zu erhalten. Alternativ können Sie auch die Eigenschaften „JNDI *“ oder „JMS *“ verwenden, um die Connection Factory zu konfigurieren. |
Destination Name |
Der Name des JMS-Ziels. Wird in der Regel vom Administrator bereitgestellt (z. B. „topic://myTopic“ oder „myTopic“). |
Destination Type |
Der Typ des JMS-Ziels. Könnte entweder „QUEUE“ oder „TOPIC“ sein. Wird in der Regel vom Administrator bereitgestellt. Die Standardeinstellung ist „QUEUE“. |
Maximum Batch Size |
Die maximale Anzahl der Meldungen, die bei jedem Aufruf des Prozessors veröffentlicht oder verarbeitet werden. |
Password |
Kennwort, das für die Authentifizierung und Autorisierung verwendet wird. |
SSL Context Service |
Der SSL Context Service wird verwendet, um Client-Zertifikatsinformationen für TLS/SSL-Verbindungen bereitzustellen. |
User Name (Benutzername) |
Für die Authentifizierung und Autorisierung verwendeter Benutzername. |
allow-illegal-chars-in-jms-header-names |
Gibt an, ob unzulässige Zeichen in Headernamen an den JMS-Broker gesendet werden sollen. In der Regel Bindestriche und Punkte. |
attributes-to-send-as-jms-headers-regex |
Gibt den regulären Ausdruck an, der die Namen der FlowFile-Attribute bestimmt, die als JMS-Header gesendet werden sollen. |
broker |
URI, die auf den Netzwerkstandort des JMS Message Broker verweist. Beispiel für ActiveMQ: „tcp://myhost:61616“. Beispiele für IBM MQ: „myhost(1414)“ und „myhost01(1414),myhost02(1414)“. |
cf |
Der vollständig qualifizierte Name der JMS ConnectionFactory-Implementierungsklasse (z. B. org.apache.activemq.ActiveMQConnectionFactory). |
cflib |
Pfad zum Verzeichnis mit zusätzlichen Ressourcen (z. B. JARs, Konfigurationsdateien usw.), die dem Klassenpfad hinzugefügt werden sollen (definiert als durch Kommas getrennte Liste von Werten). Solche Ressourcen stellen typischerweise Ziel-JMS-Clientbibliotheken für die Implementierung von ConnectionFactory dar. |
character-set |
Der Name des Zeichensatzes, der zum Konstruieren oder Interpretieren von TextMessages verwendet wird. |
connection.factory.name |
Der Name des JNDI-Objekts, das für die Connection Factory gesucht werden soll. |
java.naming.factory.initial |
Der vollständig qualifizierte Klassenname der JNDI Initial Context Factory Class (java.naming.factory.initial). |
java.naming.provider.url |
Die URL des JNDI-Anbieters, die als Wert für java.naming.provider.url verwendet werden soll. Weitere Informationen zu den zulässigen Schemas finden Sie in der URL-Dokumentation. |
java.naming.security.credentials |
Die Anmeldeinformationen, die bei der Authentifizierung mit JNDI (java.naming.security.credentials) verwendet werden. |
java.naming.security.principal |
Der Prinzipal, der bei der Authentifizierung mit JNDI (java.naming.security.principal) verwendet wird. |
message-body-type |
Der Typ des JMS-Meldungstextes, der erstellt werden soll. |
naming.factory.libraries |
Gibt jar-Dateien und/oder Verzeichnisse an, die zu ClassPath hinzugefügt werden sollen, um die JNDI-/JMS -Clientbibliotheken zu laden. Dies sollte eine durch Kommas getrennte Liste von Dateien, Verzeichnissen und/oder URLs sein. Wenn ein Verzeichnis angegeben wird, werden alle Dateien in diesem Verzeichnis einbezogen, Unterverzeichnisse jedoch nicht (d. h., es wird nicht rekursiv vorgegangen). |
record-reader |
Der Record Reader, der zum Parsen des eingehenden FlowFile in Datensätze verwendet wird. |
record-writer |
Der Record Writer, der für die Serialisierung von Datensätzen verwendet wird, bevor diese als JMS-Meldung veröffentlicht werden. |
Einschränkungen¶
Erforderliche Berechtigung |
Erläuterung |
|---|---|
reference remote resources |
Client Library Location kann auf Ressourcen über HTTP verweisen |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
Alle FlowFiles, die nicht an das JMS-Ziel gesendet werden können, werden an diese Beziehung weitergeleitet |
success |
Alle FlowFiles, die an das JMS-Ziel gesendet werden, werden an diese Beziehung weitergeleitet. |