SlowConsumer.patch
|
Relates |
|||
| is related to |
|
MaxScheduledWriteRequests is ineffective | Resolved |
[QFJ-833] Add Slow Consumer Protection Created: 08/Apr/15 Updated: 19/Oct/17 Resolved: 28/Dec/15 |
|
| Status: | Closed |
| Project: | QuickFIX/J |
| Component/s: | Engine |
| Affects Version/s: | 1.6.0 |
| Fix Version/s: | 1.6.3 |
| Type: | New Feature | Priority: | Default |
| Reporter: | James Olsen | Assignee: | James Olsen |
| Resolution: | Fixed | Votes: | 0 |
| Labels: | None | ||
| Attachments: |
SlowConsumer.patch
|
||||||||
| Issue Links: |
|
||||||||
| Description |
|
OOMs are possible where downstream consumers do not process messages fast enough. It is useful to be able to detect and prevent this, especially for MD/Quote streams. |
| Comments |
| Comment by James Olsen [ 08/Apr/15 ] |
|
Attached SlowConsumer.patch adds a MaxScheduledWriteRequests Session Setting which can be used to force a disconnect if a message backlog occurs. The MaxScheduledWriteRequests looks at the pending message queue in Mina. There will normally be additional queued messages at the TCP / OS level. |
| Comment by Christoph John [ 13/Apr/15 ] |
|
Thanks for the patch. Do you happen to have a github account and are able to open a pull request? If not, it's fine this way. |
| Comment by James Olsen [ 13/May/15 ] |
|
I'm afraid I'm not yet a github convert. |