added support for Postgres PUB/SUB.