fix: actually reconnect to postgres if conn fails. (#2772)

Co-authored-by: abelanger5 <belanger@sas.upenn.edu>
This commit is contained in:
Michał Kostrzewa
2026-01-10 23:28:37 +01:00
committed by GitHub
parent 09dd9dfbf7
commit a19a5b8ed5
+6 -4
View File
@@ -54,13 +54,15 @@ func (m *multiplexedListener) startListening() {
return
}
// acquire an exclusive connection
pgxpoolConn, _ := m.pool.Acquire(m.listenerCtx)
// listen for multiplexed messages
listener := &pgxlisten.Listener{
Connect: func(ctx context.Context) (*pgx.Conn, error) {
return pgxpoolConn.Conn(), nil
// Acquire a new connection each time
poolConn, err := m.pool.Acquire(ctx)
if err != nil {
return nil, err
}
return poolConn.Conn(), nil
},
LogError: func(innerCtx context.Context, err error) {
m.l.Warn().Err(err).Msg("error in listener")