Closed bradgessler closed 8 years ago
Change the client to call the dropped
callback per message. e.g.:
new Firehose.Consumer({
dropped: function(sequence){
console.log(sequence + "was dropped");
}
})
Merged into master. Closing.
That code is buggy and I reverted that commit until I can figure out what's causing issues. I'll probably also need to rewrite those JS client tests, they didn't catch the error and I think they aren't working as intended.
Closing this issue here since we moved the JS to a different repo. Continue at https://github.com/firehoseio/js_client/issues/3.
The client can detect a gap in the
last_message_sequence
and fire a "messagedropped" callback. This callback could be used by end users to send dropped message telemetry to a metrics server or have the client fill in the gaps by accessing their web servers.