Merge pull request #164 from sljeff/fix-typo

fix typo `exchanges`; fix print
shanbay · Jun 19, 2020 · bd45fb2 · bd45fb2
2 parents c4e6d81 + ae7ef77
commit bd45fb2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git 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
@@ -2,7 +2,7 @@ defaults: &defaults
   bus_broker_url: "amqp://guest:[email protected]:5672/"
   bus_reconnect_delay: "2s"
   bus_reinit_delay: "1s"
-  bus_exhanges:
+  bus_exchanges:
     - sbay-exchange
   bus_queues:
     - test