OpenJMS Data Source

OpenJMS is a messaging standard that allows application components to create, send, receive and read messages.

OpenJMS Data Source reads data from OpenJMS queue or topic.

The JMS (Java Message Service) supports two messaging models:

  1. Point to Point: The Point-to-Point message producers are called senders and the consumers are called receivers. They exchange messages by means of a destination called a queue: senders produce messages to a queue; receivers consume messages from a queue. What distinguishes the point-to-point messaging is that only one consumer can consume a message.

  2. Publish and Subscribe: Each message is addressed to a specific queue, and the receiving clients extract messages from the queues established to hold their messages. If no consumers are registered to consume the messages, the queue holds them until a consumer registers to consume them.

Configuring OpenJMS Data Source

To add an OpenJMS Data Source into your pipeline, drag the Data Source to the canvas and right-click on it to configure.

Under the Schema Type tab, select Fetch From Source or Upload Data File.

FieldDescription
Connection NameConnections are the Service identifiers.Select the connection name from the available list of connections, from where you would like to read the data
Queue NameDirectory path of HDFS file system.

Click on the Add Notes tab. Enter the notes in the space provided.

Click Done to save the configuration.

Top