From ae7ef774d086559cc59232dabf47dc67e459086a Mon Sep 17 00:00:00 2001
From: sljeff <shanliangjeff@qq.com>
Date: Fri, 19 Jun 2020 15:51:10 +0800
Subject: [PATCH] fix typo `exchanges`; fix print

---
 extensions/busext/amqp.go | 7 +++----
 testdata/config.yaml      | 2 +-
 2 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/extensions/busext/amqp.go b/extensions/busext/amqp.go
index c8ac9fe7..1f563038 100644
--- a/extensions/busext/amqp.go
+++ b/extensions/busext/amqp.go
@@ -215,8 +215,7 @@ func (b *BusExt) Consume() error {
 					return
 				case delivery := <-channel:
 					b.deliveryAck(delivery)
-					b.ErrorLogger.Printf("Receive delivery: %+v from queue: %v\n",
-						delivery, chName)
+					log.Printf("Receive delivery: %+v from queue: %v\n", delivery, chName)
 					var handler Handler
 					var ok bool
 					if delivery.Headers == nil {
@@ -325,7 +324,7 @@ func (b *BusExt) init(conn *amqp.Connection) error {
 		return err
 	}
 
-	for _, exchange := range b.config.GetStringSlice("exhanges") {
+	for _, exchange := range b.config.GetStringSlice("exchanges") {
 		err = ch.ExchangeDeclare(
 			exchange,
 			amqp.ExchangeTopic,
@@ -339,7 +338,7 @@ func (b *BusExt) init(conn *amqp.Connection) error {
 			b.ErrorLogger.Printf("declare exchange: %v failed: %v\n", exchange, err)
 			return err
 		}
-		b.ErrorLogger.Printf("declare exchange: %v succeeded\n", exchange)
+		log.Printf("declare exchange: %v succeeded\n", exchange)
 	}
 
 	for _, queue := range b.config.GetStringSlice("queues") {
diff --git a/testdata/config.yaml b/testdata/config.yaml
index 981b6b2b..78f31217 100644
--- a/testdata/config.yaml
+++ b/testdata/config.yaml
@@ -2,7 +2,7 @@ defaults: &defaults
   bus_broker_url: "amqp://guest:guest@127.0.0.1:5672/"
   bus_reconnect_delay: "2s"
   bus_reinit_delay: "1s"
-  bus_exhanges:
+  bus_exchanges:
     - sbay-exchange
   bus_queues:
     - test