|
@@ -279,6 +279,9 @@ func (that *Offloader) Do() { |
|
|
} else { |
|
|
} else { |
|
|
rerun := false |
|
|
rerun := false |
|
|
for k, q := range that.Sets { |
|
|
for k, q := range that.Sets { |
|
|
|
|
|
if that.Queues[q] == nil { |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
key := fmt.Sprintf("%s:%s", that.Name, k) |
|
|
key := fmt.Sprintf("%s:%s", that.Name, k) |
|
|
scard, err := scards[k].Result() |
|
|
scard, err := scards[k].Result() |
|
|
if err != nil { |
|
|
if err != nil { |
|
|