Implement drainer and per queue method callback