Ensuring lossless queues using sessions

In any production system, it is imperative that the data isn't lost when being read/written to or from a data source/target. This recipe shows how this is achieved when reading and writing to queues using the tMom component.

Getting ready

Open the job jo_cook_ch09_0090_losslesQueues.

How to do it...

In a similar fashion to creating sessions with a database, we will first add ActiveMQ connection that will create the session.

1. Open the tMomConnection component to the canvas and tick the box Use Transacted.

2. Open the tMomOutput component and tick the Use existing connection box.

3. Set the To field to losslessQueue, and the Message Type to Queue.

   Add the rollback and commit components

4. Drag a tMomCommit component to the canvas and link this to the tFixedFlowInput using an OnSubjobOk trigger.

5. Open the component and set the MQ Server to ActivMQ.

   Successful run

6. Run the job and then check the queue in the web browser.

7. You will see that the queue losslessQueue has been created...