You want to write rows from a source table into a WebSphere message queue. Then, you need to read the messages back from the queue and write them into a target table.
Solution
You can use the Websphere Queue Writer transformation in SAS Data Integration Studio
to write the data to the message queue. Then, you can use the Websphere Queue Reader
transformation to read the messages
from the queue and populate them into a target table. Perform the following tasks
to process the queue:
Text and
file transfers are also supported in message queues, but these transfers
are not covered in this example.
Tasks
Create the Websphere Queue Writer Job
Perform the following steps to create and populate the job:
Create an empty job.
Select
and drag the Websphere Queue Writer transformation from the Access folder in the Transformations tree into the empty job in the Diagram tab in the Job Editor window.
Drop the source table for the queue in the Diagram tab.
Connect the source table to the input port of the Websphere Queue Writer transformation.
Drop the queue from the Message queue folder in the Inventory tree in the Diagram tab.
Connect the queue to the output port of the Websphere Queue Writer transformation.
The job resembles the sample shown in the following display.
Write Records from Table to Queue Job
Configure and Run the Websphere Queue Writer Job
Perform the following steps to configure the job:
Open the Queue Options tab of the properties window for the Websphere
Queue Writer transformation.
Select Table in the Message Type group
box. Save the setting and close the properties window.
Run the job. If you are prompted to do so, enter a user ID and password for the default
SAS Application Server that generates and runs SAS code for the job. The server executes the SAS code for
the job.
If the job completes without error, go to the next section. If error messages appear,
read and
respond to the messages.
Verify the Websphere Queue Writer Job
Perform the following steps to verify the results of the queue writer job:
Open the
IBM WebSphere Queue Explorer application.
Select the queue that you created and ran. Then, verify that the expected messages
are sitting on
the queue.
Create the Websphere Queue Reader Job
Perform
the following steps to create the Websphere Queue Reader Job:
Create an empty job.
Select and drag the Websphere Queue Reader transformation from the Access folder in
the Transformations tree into the empty job in the Diagram tab in the Job Editor window.
Drop the queue that you created and ran on the Diagram tab.
Connect the queue to the input port of the Websphere Queue Reader transformation.
Because you want to have a permanent target table to contain the output for the transformation,
right-click the temporary work
table that is attached to the transformation and click Replace in
the pop-up menu. Then, use the Table Selector window to select the target table for the job. The target table must be registered
in SAS Data Integration Studio. (For more information
about temporary work tables, see Working with Default Temporary Output Tables.)
After
these steps have been completed, the process flow diagram for this
example resembles the following display.
Read Records to a Table Job
Configure and Run the Websphere Queue Reader Job
Perform the following steps to configure the job:
Open the Queue Options tab of the properties window for the Websphere
Queue Reader transformation.
Select Table in the Message Type group box. Save the setting and close the properties window. Remember that you verified
that the message queue contained the messages from the source table in the Verify
the Websphere Queue Writer Job section.
Run the job. If you are prompted to do so, enter a user ID and password for the default
SAS Application Server that generates and runs SAS code for the job. The server executes
the SAS code for
the job.
If the job completes without error, go to the next section. If error messages appear,
read and
respond to the messages.
Verify the Websphere Queue Reader Job
Perform the following steps to verify the results of the queue reader job:
Access
the View Data window for the source table.
Access
the View Data window for the target table. A sample target table is shown in the following example.
Sample Target Table Data
The source table and the target table contain identical data. This means that the
data was transferred successfully
through the Websphere message queue. If you do not see the data that you expected,
check the Message Format column on
the Columns tab in the Websphere Queue Reader properties window. To access
this window, right-click Websphere Queue Reader and click Properties in the pop-up menu.
Then, you can correct the formats as needed.