Skip to content
Abhishek Bhattacharjee edited this page Jun 30, 2016 · 5 revisions

SQS

Points to remember

  • Scheduler uses delay queues and delayed messages.
  • Delay queues make the messages send to them available to consumer after the specified delay(maximum 900 seconds or 15 minutes)
  • Delayed messages are made available to consumers only after the specified delay.
  • If the message is a delayed message and is sent to a delayed queue, then the message's delay takes preference and overrides the queue's delay. See example below.
  • Maximum delay for messages is 900 seconds(15 minutes)

For eg: If the queue delay is 30 seconds and a message is sent with a delay of 45 seconds, it'll be available after 45 seconds(not 30 or 75 seconds). If the message is sent with a 15 seconds delay, message will be made available after 15 seconds(not 30 or 45 seconds)

Setting up SQS for Scheduler

  • sqs.InitSQSRegions() must be called for both the consumer and publisher
  • sqs.Setup() must be called once, preferably in the publisher. Setup will create the queues required.
Clone this wiki locally