Skip to content

Commit

Permalink
[ISSUE #7068] Fix failed to create syncer topic when the proxy was ju…
Browse files Browse the repository at this point in the history
…st started (#7076)
  • Loading branch information
gaoyf authored Jul 25, 2023
1 parent 047ef74 commit 32eb1d5
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -104,6 +104,7 @@ protected MQClientAPIExt createAndStart(String instanceName) {
rpcHook);

if (!mqClientAPIExt.updateNameServerAddressList()) {
mqClientAPIExt.fetchNameServerAddr();
this.scheduledExecutorService.scheduleAtFixedRate(
mqClientAPIExt::fetchNameServerAddr,
Duration.ofSeconds(10).toMillis(),
Expand Down

0 comments on commit 32eb1d5

Please sign in to comment.