Merge 4e8a29a into 17631e1

gocelery · Aug 24, 2019 · e450f7f · e450f7f
2 parents 17631e1 + 4e8a29a
commit e450f7f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/redis_broker.go b/redis_broker.go
@@ -64,7 +64,7 @@ func (cb *RedisCeleryBroker) SendCeleryMessage(message *CeleryMessage) error {
 func (cb *RedisCeleryBroker) GetCeleryMessage() (*CeleryMessage, error) {
 	conn := cb.Get()
 	defer conn.Close()
-	messageJSON, err := conn.Do("BLPOP", cb.queueName, "1")
+	messageJSON, err := conn.Do("BRPOP", cb.queueName, "1")
 	if err != nil {
 		return nil, err
 	}