Listeners

class hermes.listeners.PostgresNotificationListener(pg_connector, notif_channel, notif_queue, error_strategy, error_queue, fire_on_start=True)

Bases: hermes.components.Component

A listener to detect event notifications from Postgres and pass onto to a processor.

Parameters:

• pg_connector – A PostgresConnector object
• notif_channel – The string representing the notification channel to listen to updates on
• notif_queue – A Queue to be used for notification events.
• error_strategy – A CommonErrorStrategy subclass
• error_queue – A Queue to be used for error events.