You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Many services have SQS observers. There are differences in the implementations across services, but what what we know for sure is that the SQS queue is polled, the worker processes all received messages one by one and deletes successfully processed messages.
What exactly happens with the obtained SQS message is an implementation detail of the worker, but there is a lot of logic which can be reused. I would like to see an SQS Observer decorator which will implement the existing WorkerInterface. The SQS Decorator will decorate a worker which in addition to the WorkerInterface has an additional setSqsMessage(array $sqsMessage) method.
There are more details, i.e. what to do if a message is malformed, logging, how does the worker reschedule which we can find the best solutions for and apply to existing and future SQS observers.
The text was updated successfully, but these errors were encountered:
The worker being provided the SQS Message also needs a unsetSqsMessage() method or alternatively the SQS observer decorator needs a worker factory or worker builder factory.
Many services have SQS observers. There are differences in the implementations across services, but what what we know for sure is that the SQS queue is polled, the worker processes all received messages one by one and deletes successfully processed messages.
What exactly happens with the obtained SQS message is an implementation detail of the worker, but there is a lot of logic which can be reused. I would like to see an SQS Observer decorator which will implement the existing WorkerInterface. The SQS Decorator will decorate a worker which in addition to the WorkerInterface has an additional
setSqsMessage(array $sqsMessage)
method.There are more details, i.e. what to do if a message is malformed, logging, how does the worker reschedule which we can find the best solutions for and apply to existing and future SQS observers.
The text was updated successfully, but these errors were encountered: