We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 13b550e commit 0a74505Copy full SHA for 0a74505
1 file changed
src/Pulsar.Client/Api/AutoClusterFailover.fs
@@ -167,7 +167,7 @@ type AutoClusterFailover
167
| Some ctx -> do! ctx.UpdateServiceInfo(sec.ServiceInfo)
168
| None -> ()
169
| AutoClusterDecision.SwitchToPrimary ->
170
- Log.Logger.LogInformation("Switching back to primary cluster {0}", primary)
+ Log.Logger.LogInformation("Switching back to primary cluster {0}", primary.ServiceUrl)
171
currentServiceInfo <- primaryServiceInfo
172
match context with
173
| Some ctx -> do! ctx.UpdateServiceInfo(primary)
@@ -201,8 +201,8 @@ type AutoClusterFailover
201
t.AutoReset <- false
202
t.Elapsed.Add(fun _ ->
203
backgroundTask {
204
- do! tick()
205
if not isDisposed then
+ do! tick()
206
try t.Start() with _ -> ()
207
} |> ignore)
208
t :> IDisposable
0 commit comments