| commit | 030cb410f0e4ddf46f16c8e0f20e6800a21a3929 | [log] [tgz] |
|---|---|---|
| author | Jim Gomes <jgomes@apache.org> | Wed Oct 19 23:29:35 2011 +0000 |
| committer | Jim Gomes <jgomes@apache.org> | Wed Oct 19 23:29:35 2011 +0000 |
| tree | d2ea5f508b528b52e50b0b15367bb601aded7287 | |
| parent | 64a8251b1f84f71475d47a1e089fcb028bfc88bc [diff] |
Add locking around iterating over recoveringPullConsumers. Add check for pre-existing consumer ID to avoid exception throw while recovering.