From 80a3345d4f28370a6dc3358fe22c12d0ca665dd1 Mon Sep 17 00:00:00 2001
From: Demian <thde@users.noreply.github.com>
Date: Tue, 26 Oct 2021 11:53:16 +0000
Subject: [PATCH] docs: fix examples

---
 README.md | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/README.md b/README.md
index 24b6798..bb8ecfe 100644
--- a/README.md
+++ b/README.md
@@ -36,7 +36,7 @@ go get github.com/wagslane/go-rabbitmq
 ### Default options
 
 ```go
-consumer, err := rabbitmq.NewConsumer("amqp://user:pass@localhost")
+consumer, err := rabbitmq.NewConsumer("amqp://user:pass@localhost", amqp.Config{})
 if err != nil {
     log.Fatal(err)
 }
@@ -59,16 +59,17 @@ if err != nil {
 ```go
 consumer, err := rabbitmq.NewConsumer(
     "amqp://user:pass@localhost",
+    amqp091.Config{},
     rabbitmq.WithConsumerOptionsLogging,
 )
 if err != nil {
     log.Fatal(err)
 }
 err = consumer.StartConsuming(
-    func(d rabbitmq.Delivery) bool {
+    func(d rabbitmq.Delivery) rabbitmq.Action {
         log.Printf("consumed: %v", string(d.Body))
-        // true to ACK, false to NACK
-        return true
+        // rabbitmq.Ack, rabbitmq.NackDiscard, rabbitmq.NackRequeue
+        return rabbitmq.Ack
     },
     "my_queue",
     []string{"routing_key1", "routing_key2"},
@@ -86,7 +87,7 @@ if err != nil {
 ### Default options
 
 ```go
-publisher, returns, err := rabbitmq.NewPublisher("amqp://user:pass@localhost")
+publisher, returns, err := rabbitmq.NewPublisher("amqp://user:pass@localhost", amqp091.Config{})
 if err != nil {
     log.Fatal(err)
 }
@@ -101,6 +102,7 @@ if err != nil {
 ```go
 publisher, returns, err := rabbitmq.NewPublisher(
     "amqp://user:pass@localhost",
+    amqp091.Config{},
     // can pass nothing for no logging
     rabbitmq.WithPublisherOptionsLogging,
 )