1. class
  2. Illuminate
  3. \
  4. Foundation
  5. \
  6. Cloud
  7. \
  8. QueueConnector

QueueConnector

class QueueConnector implements ConnectorInterface (View source)

Methods

__construct(ConnectorInterface $connector, Application $app)

Create a new instance.

Queue
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

at line 27
__construct(ConnectorInterface $connector, Application $app)

Create a new instance.

Parameters

ConnectorInterface $connector
Application $app

at line 37
Queue connect(array $config)

Establish a queue connection.

Parameters

array $config

Return Value

Queue

at line 66
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

at line 89
protected void configureQueue(Queue $queue)

Configure the queue.

Parameters

Queue $queue

Return Value

void

at line 99
protected void configureWorker(Queue $queue)

Configure the queue worker.

Parameters

Queue $queue

Return Value

void

at line 123
protected void configureFailedJobProvider(Queue $queue)

Configure the failed job provider.

Parameters

Queue $queue

Return Value

void