updated readme and example

stanipetrosyan · Mar 30, 2024 · 122fb7c · 122fb7c
1 parent aa5b05d
commit 122fb7c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -71,7 +71,7 @@ A processor works like a middleware, in fact forwards messages only if the predi
 ```go
 
 eventbus.Channel("topic1").Processor(func(message goeventbus.Message) bool {
-	return message.
+	return message.Options.Headers().Contains("header")
 })
 ```
 

diff --git a/examples/main.go b/examples/main.go
@@ -20,7 +20,7 @@ func main() {
 	})
 
 	eventbus.Channel("topic1").Processor(func(message goeventbus.Message) bool {
-		return message.Data == "Hi topic 1"
+		return message.Options.Headers().Contains("header")
 	})
 
 	eventbus.Channel("topic2").Subscriber().Listen(func(dc goeventbus.Context) {
@@ -49,10 +49,10 @@ func publishTo(address string, data string) {
 	message := goeventbus.CreateMessage().SetBody(data).SetOptions(options)
 	for {
 		eventbus.Channel(address).Publisher().Publish(message)
-		time.Sleep(time.Second * 2)
+		time.Sleep(time.Second)
 	}
 }
 
 func printMessage(data goeventbus.Message) {
-	fmt.Printf("Message %s, Headers %s\n", data.Data, data.Options)
+	fmt.Printf("Message %s, Headers %s\n", data.Data, data.Options.Headers())
 }
-Original file line number
+Diff line change
@@ Expand Up @@
     ```go
     eventbus.Channel("topic1").Processor(func(message goeventbus.Message) bool {
-    	return message.
+    	return message.Options.Headers().Contains("header")
     })
     ```
@@ Expand Down @@