| Index: filter/count/tq.go
|
| diff --git a/filter/count/tq.go b/filter/count/tq.go
|
| index 32b32d97b53fb8047253ac542ea50a7c21b159c4..f2be798f560f2e6ebcf5a6420cd8c5e37a7c77ee 100644
|
| --- a/filter/count/tq.go
|
| +++ b/filter/count/tq.go
|
| @@ -42,8 +42,8 @@ func (t *tqCounter) Stats(queueNames []string, cb tq.RawStatsCB) error {
|
| return t.c.Stats.up(t.tq.Stats(queueNames, cb))
|
| }
|
|
|
| -func (t *tqCounter) Testable() tq.Testable {
|
| - return t.tq.Testable()
|
| +func (t *tqCounter) GetTestable() tq.Testable {
|
| + return t.tq.GetTestable()
|
| }
|
|
|
| // FilterTQ installs a counter TaskQueue filter in the context.
|
|
|