show what to replace
This commit is contained in:
parent
adfd010a93
commit
2515bd3339
1 changed files with 3 additions and 2 deletions
|
|
@ -78,10 +78,11 @@ import (
|
|||
func main() {
|
||||
events := make(chan []string, 1)
|
||||
|
||||
// simulating a high incoming message load
|
||||
event := []string{"some_text", "some_id"}
|
||||
tryCrash := func() {
|
||||
for {
|
||||
events <- []string{"some_text", "some_id"}
|
||||
// replace "event" with whatever is giving you events: pubsub, amqp messages…
|
||||
events <- event
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue