in rocketmq-client-csharp/Client.cs [75:92]
public virtual async Task Start()
{
schedule(async () =>
{
await UpdateTopicRoute();
}, 30, _updateTopicRouteCts.Token);
// Get routes for topics of interest.
await UpdateTopicRoute();
string accessPointUrl = _accessPoint.TargetUrl();
createSession(accessPointUrl);
await _sessions[accessPointUrl].AwaitSettingNegotiationCompletion();
await Heartbeat();
}