We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f315c9e commit 0f2d9bbCopy full SHA for 0f2d9bb
examples/pubsub/sub/sub.go
@@ -52,9 +52,10 @@ var importantSubscription = &common.Subscription{
52
func main() {
53
s := daprd.NewService(":8080")
54
55
- if err := s.AddBulkTopicEventHandler(defaultSubscription, eventHandler, 10, 100); err != nil {
56
- log.Fatalf("error adding topic subscription: %v", err)
57
- }
+ // use this for bulk subscription
+ // if err := s.AddBulkTopicEventHandler(defaultSubscription, eventHandler, 10, 100); err != nil {
+ // log.Fatalf("error adding topic subscription: %v", err)
58
+ // }
59
60
if err := s.AddTopicEventHandler(defaultSubscription, eventHandler); err != nil {
61
log.Fatalf("error adding topic subscription: %v", err)
0 commit comments