We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0dbe3fc commit 16753dcCopy full SHA for 16753dc
2 files changed
README.md
@@ -115,8 +115,6 @@ core = Core()
115
topic = core.get_topic(topic_name='topicName') # By default, process messages concurrently which are available CPU cores
116
topic = core.get_topic(topic_name='topicName', max_concurrent_messages=10) # Process 10 messages concurrently
117
118
-
119
120
```
121
122
### Publishing message to topic
src/example.py
@@ -48,7 +48,7 @@ def process(message):
48
print(e)
49
50
51
-# subscribe(topic, subscription)
+subscribe(topic, subscription)
52
# for x in range(10):
53
# publish_messages(topic_name=topic)
54
0 commit comments