diff --git a/internal/replication/replicationchannel/replicationchannel.go b/internal/replication/replicationchannel/replicationchannel.go index 1552beed..6dd4f5d6 100644 --- a/internal/replication/replicationchannel/replicationchannel.go +++ b/internal/replication/replicationchannel/replicationchannel.go @@ -144,8 +144,8 @@ func (rc *ReplicationChannel) StartReplicationChannel( return nil } - restartLSN, err := replicationConnection.StartReplication(pluginArguments) - if err != nil { + restartLSN, err := replicationConnection.StartReplication(pluginArguments) + if err != nil { if rc.shutdownRequested.Load() { // If we tried to start replication before the shutdown was initiated, // we totally expect that to fail, and we can just ignore the error