Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions docs/content/advanced/delayed-messages.md
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@ You can also use `delay.Until` instead of `delay.For` to specify `time.Time` ins
## Supported Pub/Subs

* [PostgreSQL](/pubsubs/sql/)
* [MySQL](/pubsubs/sql/)

## Full Example

Expand Down
2 changes: 1 addition & 1 deletion docs/content/advanced/requeuing-after-error.md
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,6 @@ A better way to use the `Requeuer` is to combine it with the `Poison` middleware
The middleware moves messages to a separate "poison" topic.
Then, the requeuer moves them back to the original topic based on the metadata.

You combine this with a Pub/Sub that supports delayed messages.
You combine this with a Pub/Sub that [supports delayed messages](/advanced/delayed-messages/#supported-pubsubs).
See the [full example based on PostgreSQL](https://github.com/ThreeDotsLabs/watermill/blob/master/_examples/real-world-examples/delayed-requeue/main.go).

3 changes: 2 additions & 1 deletion docs/content/pubsubs/sql.md
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,8 @@ You can use it to filter messages by some condition in the payload or in the met
Additionally, you can choose to delete messages from the table after they are acknowledged.
Thanks to this, the table doesn't grow in size with time.

Currently, this schema is supported only for PostgreSQL.
This schema is supported by both PostgreSQL and MySQL.
The example below is based on PostgreSQL, but the same approach can be used with MySQL.

{{% load-snippet-partial file="src-link/watermill-sql/pkg/sql/queue_schema_adapter_postgresql.go" first_line_contains="// PostgreSQLQueueSchema" last_line_contains="}" %}}

Expand Down