Skip to main content Skip to complementary content

Creating a Job for retrieving Amazon SQS messages

Create a Job to open a connection to access Amazon SQS, then retrieve all messages from an existing Amazon SQS queue, finally delete the queue.

Prerequisites: You must deliver the following message creator attribute and message body data to the Amazon SQS queue named talend in order to replicate this scenario.

#Creator;Body
Talend DOC Team;the 1st message from Talend DOC team
Talend DEV Team;the 2nd message from Talend DEV team
Talend QA Team;the 3rd message from Talend QA team

Procedure

  1. Create a new Job and add a tSQSConnection component, a tSQSInput component, a tLogRow component, and a tSQSQueueDelete component by typing their names in the design workspace or dropping them from the Palette.
  2. Link the tSQSInput component to the tLogRow component using a Row > Main connection.
  3. Link the tSQSConnection component to the tSQSInput component using a Trigger > OnSubjobOk connection.
  4. Link the tSQSInput component to the tSQSQueueDelete component using a Trigger > OnSubjobOk connection.

Did this page help you?

If you find any issues with this page or its content – a typo, a missing step, or a technical error – let us know how we can improve!

Leave your feedback here