v4.0.0-rc.1
Pre-release
Pre-release
- Added
PostgreSQLQueueSchema
andPostgreSQLQueueOffsetsAdapter
.- This schema is similar to the original one, except it allows filtering messages with a custom
WHERE
clause. - It doesn't support customer groups.
- It allows deleting messages from the table after acking (optional).
- This schema is similar to the original one, except it allows filtering messages with a custom
- Added
NewDelayedPostgreSQLPublisher
andNewDelayedPostgresSQLSubscriber
- They work on top of the conditional schema and use the
delay
component implemented in ThreeDotsLabs/watermill#469 - The idea is to receive messages with a delay or at a given time in a simple way.
- They work on top of the conditional schema and use the
- Reworked the
SchemaAdapter
andOffsetsAdapter
interfaces (Breaking change -> will bump the major to v4).- We had a few instances where some details have been missing from one of the interface methods. It makes it difficult to extend this library with new features, as each will require a major version bump, and we want to avoid it if possible.
- To mitigate this, we're moving to a
params
struct passed to the methods instead of raw arguments. It adds some verbosity but allows extending the params if needed with no breaking changes to the library. - The methods now also return errors.
- Migration: if you don't use a custom schema/offsets adapter, you don't need to do anything. If you do, change the methods to implement the new interfaces. Use values from the
params
argument and return errors.