skip endOfPeriodMarker in stream method

[mikewuhao]

the windowOffset calculate method is diffrent between relay and client . Client filters the endOfPeriodMarker event as follows: if (e.isEndOfPeriodMarker()) { ... } else if (e.isCheckpointMessage()) { ... } else // regular dbusEvent { if (currentWindowScn == e.sequence()) { ++currentWindowOffset; } else { currentWindowScn = e.sequence(); currentWindowOffset = 1L; } } but when the client stream events from relay , the filter method like this: if (state == EventScanningState.FOUND_WINDOW_ZONE) { if (skippedMessages < messagesToSkip) { ++skippedMessages; continue; } else { state = EventScanningState.VALID_ZONE; } } } so when transaction has a lot events and the client's buffer is full.the windowOffset may be not right and the consumer may consume a event twice.