Added not-too-classy Retry mechanism to allow harbor source to retry reading
(with timeout) when websocket got a text frame.