Index: filter/featureBreaker/tq.go |
diff --git a/filter/featureBreaker/tq.go b/filter/featureBreaker/tq.go |
index 14a51e70bbb73ad7846bdfe8ece5c8502369bbea..c5c84482c67e91159d8ae844530c8c16c2004df1 100644 |
--- a/filter/featureBreaker/tq.go |
+++ b/filter/featureBreaker/tq.go |
@@ -34,8 +34,8 @@ func (t *tqState) Stats(queueNames []string, cb tq.RawStatsCB) error { |
return t.run(func() error { return t.tq.Stats(queueNames, cb) }) |
} |
-func (t *tqState) Testable() tq.Testable { |
- return t.tq.Testable() |
+func (t *tqState) GetTestable() tq.Testable { |
+ return t.tq.GetTestable() |
} |
// FilterTQ installs a featureBreaker TaskQueue filter in the context. |