Auto recover when counter is reset

[ramontayag]

When the counter in the source is reset, this gem won't get messages anymore (or more precisely, when the message count reaches what this gem has stored).

When the response is empty with a -1 message_id, this is what MessageBus shows:

[
    {
        "global_id": -1,
        "message_id": -1,
        "channel": "/__status",
        "data": {
            "/v2/tx_events": 504
        }
    }
]

We can see what message_id to continue reading from and recover.