Skip to content

Commit 32942cc

Browse files
docs: add suport of mysql delayed messages (#630)
Co-authored-by: adrian.zajkowski <adrian.zajkowski@nordsec.com>
1 parent 98c1107 commit 32942cc

File tree

3 files changed

+4
-2
lines changed

3 files changed

+4
-2
lines changed

docs/content/advanced/delayed-messages.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ You can also use `delay.Until` instead of `delay.For` to specify `time.Time` ins
3737
## Supported Pub/Subs
3838

3939
* [PostgreSQL](/pubsubs/sql/)
40+
* [MySQL](/pubsubs/sql/)
4041

4142
## Full Example
4243

docs/content/advanced/requeuing-after-error.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,6 @@ A better way to use the `Requeuer` is to combine it with the `Poison` middleware
5050
The middleware moves messages to a separate "poison" topic.
5151
Then, the requeuer moves them back to the original topic based on the metadata.
5252

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

docs/content/pubsubs/sql.md

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,8 @@ You can use it to filter messages by some condition in the payload or in the met
117117
Additionally, you can choose to delete messages from the table after they are acknowledged.
118118
Thanks to this, the table doesn't grow in size with time.
119119

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

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

0 commit comments

Comments
 (0)