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. |