THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Alternatives
| Component Class | org.apache.nifi.jms.processors.standard.ConsumeJMS |
| Bundle Group | org.apache.nifi |
| Bundle Artifact | nifi-standardjms-processors-nar |
Migration
GetJMSQueue supports retrieving messages using the Java Message Service Queue interface to access Apache ActiveMQ.
...
GetJMSTopic
| Component Class | org.apache.nifi.processors.standard.GetJMSTopic |
| Bundle Group | org.apache.nifi |
| Bundle Artifact | nifi-standard-nar |
| Deprecation Type | Component Class |
| Deprecated Version | 1.3.0 |
| Migration Difficulty | MEDIUM |
| Migration Type | Component Replacement |
Alternatives
| Component Class | org.apache.nifi.jms.processors |
.ConsumeJMS | |
| Bundle Group | org.apache.nifi |
| Bundle Artifact | nifi-jms- |
| processors-nar |
Migration
GetJMSTopic supports retrieving messages using the Java Message Service Topic interface to access Apache ActiveMQ.
...
ConsumeJMS should be configured with a Connection Factory Service implementation of JMSConnectionFactoryProvider with required properties. The ActiveMQ Artemis library provides the current supported version of JMS access.
| Property | Value |
|---|---|
| JMS Connection Factory Implementation Class | org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory |
| JMS Client Libraries | /opt/activemq-artemis-2.28.0/lib |
| JMS Broker URI | tcp://${AMQ_HOST}:61616 |
ConsumeJMS uses the Connection Factory Service along with several other properties to access JMS Queues.
| Property | Value |
|---|---|
| Connection Factory Service | JMSConnectionFactoryProvider |
| Destination Name | |
| Destination Type | TOPIC |
Flow Definitions
The Deprecated Flow Definition includes GetJMSTopic configured for ActiveMQ running on the localhost address with a specified Destination Name.
...
The Migrated Flow Definition includes ConsumeJMS configured with a JMSConnectionFactoryProvider using the same JMS broker information. The Migrated Flow Definition includes a JMS Parameters context with a Parameter named JmsClientLibrariesPath referencing the local directory containing the Apache ActiveMQ Artemis libraries.
HashAttribute
| Component Class | org.apache.nifi.processors.standard.HashAttribute |
| Bundle Group | org.apache.nifi |
| Bundle Artifact | nifi-standard-nar |
| Deprecation Type | Component Class |
| Deprecated Version | 1.21.0 |
| Migration Difficulty | LOW |
| Migration Type | Component Replacement |
...
The Migrated Flow Definition includes InvokeHTTP configured to send to ListenHTTP using equivalent settings.
PutJMS
| Component Class | org.apache.nifi.processors.standard.PutJMS |
| Bundle Group | org.apache.nifi |
| Bundle Artifact | nifi-standard-nar |
| Deprecation Type | Component Class |
| Deprecated Version | 1.3.0 |
| Migration Difficulty | MEDIUM |
| Migration Type | Component Replacement |
Alternatives
| Component Class | org.apache.nifi.jms.processors.PublishJMS |
| Bundle Group | org.apache.nifi |
| Bundle Artifact | nifi-jms-processors-nar |
Migration
PutJMS supports sending messages using the Java Message Service interface to access Apache ActiveMQ.
PutJMS bundles the ActiveMQ libraries and requires the URL property to specify the JMS server location, and the Destination Name property to specify the JMS destination. PutJMS also supports a configurable Destination Type of Queue or Topic.
The PublishJMS Processor supports similar functionality to PutJMS, but requires additional configuration. PublishJMS does not bundle JMS libraries and requires referencing a local directory containing implementation JAR files.
PublishJMS should be configured with a Connection Factory Service implementation of JMSConnectionFactoryProvider with required properties. The ActiveMQ Artemis library provides the current supported version of JMS access.
| Property | Value |
|---|---|
| JMS Connection Factory Implementation Class | org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory |
| JMS Client Libraries | /opt/activemq-artemis-2.28.0/lib |
| JMS Broker URI | tcp://${AMQ_HOST}:61616 |
PublishJMS uses the Connection Factory Service along with several other properties to access JMS destinations.
| Property | Value |
|---|---|
| Connection Factory Service | JMSConnectionFactoryProvider |
| Destination Name | |
| Destination Type |
Flow Definitions
The Deprecated Flow Definition includes PutJMS configured for ActiveMQ running on the localhost address with a specified Destination Name.
The Migrated Flow Definition includes PublishJMS configured with a JMSConnectionFactoryProvider using the same JMS broker information. The Migrated Flow Definition includes a JMS Parameters context with a Parameter named JmsClientLibrariesPath referencing the local directory containing the Apache ActiveMQ Artemis libraries.