class QueueConnector implements ConnectorInterface (View source)

Methods

__construct(ConnectorInterface $connector, Application $app)

Create a new instance.

connect(array $config)

Establish a queue connection.

void
registerErrorHandling(SqsClient $sqs, Queue $queue)

Register SQS client middleware that translates "queue does not exist" errors into ManagedQueueNotFoundExceptions.

void
configureQueue(Queue $queue)

Configure the queue.

void
configureWorker(Queue $queue)

Configure the queue worker.

void
configureFailedJobProvider(Queue $queue)

Configure the failed job provider.

Details

__construct(ConnectorInterface $connector, Application $app)

Create a new instance.

Parameters

ConnectorInterface $connector
Application $app

Queue connect(array $config)

Establish a queue connection.

Parameters

array $config

Return Value

Queue

protected void registerErrorHandling(SqsClient $sqs, Queue $queue)

Register SQS client middleware that translates "queue does not exist" errors into ManagedQueueNotFoundExceptions.

Parameters

SqsClient $sqs
Queue $queue

Return Value

void

protected void configureQueue(Queue $queue)

Configure the queue.

Parameters

Queue $queue

Return Value

void

protected void configureWorker(Queue $queue)

Configure the queue worker.

Parameters

Queue $queue

Return Value

void

protected void configureFailedJobProvider(Queue $queue)

Configure the failed job provider.

Parameters

Queue $queue

Return Value

void

Laravel Cloud is the best place to deploy Laravel, Nuxt, Express, Hono, Node.js, Bun, Go, Flask, Python, and more, with dedicated infrastructure available on AWS through Laravel Private Cloud.