From 0bdd8fa77dc0b165d61d3b40e605eb9110fd6cf8 Mon Sep 17 00:00:00 2001 From: Charles Chan Date: Tue, 19 May 2020 06:10:16 -0700 Subject: [PATCH] Fix typos in Redis broker (#549) --- v1/brokers/redis/goredis.go | 4 ++-- v1/brokers/redis/redis.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/v1/brokers/redis/goredis.go b/v1/brokers/redis/goredis.go index 81131e899..463b770e7 100644 --- a/v1/brokers/redis/goredis.go +++ b/v1/brokers/redis/goredis.go @@ -40,7 +40,7 @@ func NewGR(cnf *config.Config, addrs []string, db int) iface.Broker { var password string parts := strings.Split(addrs[0], "@") if len(parts) == 2 { - // with passwrod + // with password password = parts[0] addrs[0] = parts[1] } @@ -301,7 +301,7 @@ func (b *BrokerGR) consumeOne(delivery []byte, taskProcessor iface.TaskProcessor // If the task is not registered, we requeue it, // there might be different workers for processing specific tasks if !b.IsTaskRegistered(signature.Name) { - log.INFO.Printf("Task not registered with this worker. Requeing message: %s", delivery) + log.INFO.Printf("Task not registered with this worker. Requeuing message: %s", delivery) b.rclient.RPush(getQueueGR(b.GetConfig(), taskProcessor), delivery) return nil diff --git a/v1/brokers/redis/redis.go b/v1/brokers/redis/redis.go index eb86365b0..cbad3b021 100644 --- a/v1/brokers/redis/redis.go +++ b/v1/brokers/redis/redis.go @@ -314,7 +314,7 @@ func (b *Broker) consumeOne(delivery []byte, taskProcessor iface.TaskProcessor) if signature.IgnoreWhenTaskNotRegistered { return nil } - log.INFO.Printf("Task not registered with this worker. Requeing message: %s", delivery) + log.INFO.Printf("Task not registered with this worker. Requeuing message: %s", delivery) conn := b.open() defer conn.Close()