Merge pull request #1 from wanelo/pg_replication

Add pg_replication check
if the line coming in doesn't parse, we won't have type, etc so move the usage up them up into the if to avoid explosions
fix for node 10+, add a data listener to the incoming message so it unpauses the stream