Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
var lowest = _outstandingMessages.GetLowestPosition();
var lowestBufferedRetry = _streamBuffer.GetLowestRetry();
Log.Debug("Lowest from outstanding is " + lowest);
Log.Debug("Lowest from streambuffer is " + lowestBufferedRetry);
lowest = Math.Min(lowest, lowestBufferedRetry);
if (lowest == int.MinValue) lowest = _lastKnownMessage;
//no outstanding messages. in this case we can say that the last known
//event would be our checkpoint place (we have already completed it)
var difference = lowest - _lastCheckPoint;
Log.Debug("lastCheckPoint is " + _lastCheckPoint);
Log.Debug("difference is " + difference);
[PID:253560:010 2016.09.14 15:42:20.640 DEBUG PersistentSubscripti] Lowest from outstanding is -2147483648
[PID:253560:010 2016.09.14 15:42:20.640 DEBUG PersistentSubscripti] Lowest from streambuffer is 2147483647
[PID:253560:010 2016.09.14 15:42:20.640 DEBUG PersistentSubscripti] lastCheckPoint is -1
[PID:253560:010 2016.09.14 15:42:20.640 DEBUG PersistentSubscripti] difference is 1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.