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 3936a02 commit 153d056Copy full SHA for 153d056
tailmq.go
@@ -9,7 +9,6 @@ import (
9
"net/url"
10
"strings"
11
"time"
12
- "context"
13
14
"github.com/olaurendeau/tailmq/consumer"
15
"github.com/streadway/amqp"
@@ -42,8 +41,6 @@ type Config struct {
42
41
func main() {
43
var err error
44
45
- ctx := context.Background()
46
-
47
config := new(Config)
48
49
config.uri = flag.String("uri", "amqp://guest:guest@localhost:5672/", "RabbitMQ amqp uri")
@@ -80,8 +77,6 @@ func main() {
80
77
printDelivery(d, config)
81
78
case err := <-c.Err:
82
79
failOnError(err, "Fail consuming")
83
- case <-ctx.Done():
84
- return
85
}
86
87
0 commit comments