If for a certain period of time (N minutes) no messages arrive from Ethereum stream - throw an error. Repeat the error every M minutes?