Skip to content

Commit

Permalink
update example
Browse files Browse the repository at this point in the history
  • Loading branch information
isayme committed Sep 30, 2018
1 parent 4a0b8da commit e71660a
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
5 changes: 2 additions & 3 deletions example/close/demo.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import (
"log"
"time"

"code.teambition.com/soa/go-lib/pkg/ilog"
"github.com/streadway/amqp"

"github.com/isayme/go-amqp-reconnect/rabbitmq"
Expand Down Expand Up @@ -69,10 +68,10 @@ func main() {
}()

time.Sleep(5 * time.Second)
ilog.Info(consumeCh.Close())
log.Print(consumeCh.Close())

time.Sleep(5 * time.Second)
ilog.Info(conn.Close())
log.Print(conn.Close())

time.Sleep(10 * time.Second)
}
1 change: 1 addition & 0 deletions example/reconnect/demo.go
Original file line number Diff line number Diff line change
Expand Up @@ -64,6 +64,7 @@ func main() {

for msg := range d {
log.Printf("msg: %s", string(msg.Body))
msg.Ack(true)
}
}()

Expand Down

0 comments on commit e71660a

Please sign in to comment.