diff --git a/go.mod b/go.mod index cb3eb31f1..616c424bd 100644 --- a/go.mod +++ b/go.mod @@ -4,6 +4,8 @@ go 1.22.0 toolchain go1.22.4 +replace github.com/go-vela/server => ../server + require ( github.com/Bose/minisentinel v0.0.0-20200130220412-917c5a9223bb github.com/DATA-DOG/go-sqlmock v1.5.2 diff --git a/queue/redis/pop.go b/queue/redis/pop.go index 2fe32ae29..36592b463 100644 --- a/queue/redis/pop.go +++ b/queue/redis/pop.go @@ -15,8 +15,6 @@ import ( // Pop grabs an item from the specified channel off the queue. func (c *client) Pop(ctx context.Context, inRoutes []string) (*models.Item, error) { - c.Logger.Tracef("popping item from queue %s", c.GetRoutes()) - // define routes to pop from var routes []string @@ -27,6 +25,8 @@ func (c *client) Pop(ctx context.Context, inRoutes []string) (*models.Item, erro routes = c.GetRoutes() } + c.Logger.Tracef("popping item from queue %s", routes) + // build a redis queue command to pop an item from queue // // https://pkg.go.dev/github.com/go-redis/redis?tab=doc#Client.BLPop