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