Skip to content

Commit 0acf176

Browse files
authored
fix: docs example
1 parent 2c4f136 commit 0acf176

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

README.md

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,9 @@ taskiq_broker = BrokerWrapper(broker)
7171
# create periodic task
7272
taskiq_broker.task(
7373
message="Hi!",
74-
subject="test-subject"
74+
# If you are using rabbitmq, then you need to replace subject with queue.
75+
# If you are using kafka, then you need to replace subject with topic.
76+
subject="test-subject",
7577
schedule=[{
7678
"cron": "* * * * *",
7779
}],

0 commit comments

Comments
 (0)