func (s *PostgresSQL) proxyNotifcations() {
    for {
        log.Info("proxy start for loop")
        if s.listener != nil {
            select {
            case evt, ok := <-s.listener.Notify:
                log.Infof("reviced on orginal channel. ok = %v", ok)
                if ok {
                    log.Infof("Got notification from listener: %v", evt)

                    ce := changeEvent{}
                    err := json.Unmarshal([]byte(evt.Extra), &ce)
                    if err != nil {
                        log.Errorf("Error unmarshal change event: %v", err)
                    }

                    s.notifications <- ce
                    // if I don't have continue here, then the for loop never runs again.
                    continue
                }
            }
        }
        return
    }
}