Constructor
new DBQueueClient()
- Source:
Example
queue-messages = db://?bk-pool=dynamodb
queue-store = db://?bk-pool=pg&bk-visibilityTimeout=300&bk-queueCount=2DBQueueClient
module:queue. DBQueueClient
Queue client using a database for persistence, this driver uses naive content resolution method by SELECT first and then UPDATE received record with new visibilityTimeout, this relies on the database to atomically perform conditional UPDATE, if no record updated it is ignored and performs SELECT again.
This is not supposed to be used in production but only for development without external tools like AWS, Redis.
It supports the same behaviour as Redis/SQS clients regarding visibilityTimeout.
To create bk_queue table run as:
bksh -db-create-tables -queue-default db://