Open StephenSorriaux opened 2 weeks ago
Before this change the listener could get forever stuck doing nothing since StartReplication() does not raise an error if the replication slot is already active. Added IsReplicationActive() to the repository to check it before starting the stream.
StartReplication()
IsReplicationActive()
Before this change the listener could get forever stuck doing nothing since
StartReplication()
does not raise an error if the replication slot is already active. AddedIsReplicationActive()
to the repository to check it before starting the stream.