Queue

Queue copied to clipboard

What's expect of a driver? What's expect of a `Consumer` implementation? Maybe something with some solid examples of implementing internal classes for the library.

chrisguitarguy

Consider using queue interprop as abstraction for queues

1

Hello! Please look at https://github.com/queue-interop/queue-interop project. Using interfaces from it allows us reuse some implementations like enqueue, which supports a lot of transports. You can outsource some code

makasim

Something simple like a lifecycle that stops the consumer after X messages.

chrisguitarguy

There Should be a `CannotRetry` class of Errors

2

These would cause the job to fail and skip the retry system completely. This is specifically interesting for serialization errors. Right now those are marked as driver errors, but really...

chrisguitarguy

jrughani9