Flow control

When teaming a high throughput operator with a low throughput one realized that the blocking queue construct was not blocking because the wrong method was being called. Also cleaned the retry logic.