Skip to content

Commit 31f9735

Browse files
[.NET] remove hardcoded client Id from samples whose connection strings already include client ids (#595)
Specifying 2 different client Ids crashed the app
1 parent ac96ff5 commit 31f9735

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

dotnet/samples/CounterClient/RpcCommandRunner.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
1414
{
1515
try
1616
{
17-
// MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration!.GetConnectionString("Default")! + ";ClientId=sampleClient-" + Environment.TickCount);
17+
// MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration!.GetConnectionString("Default")!);
1818
MqttConnectionSettings mcs = MqttConnectionSettings.FromEnvVars();
1919

2020
await mqttClient.ConnectAsync(mcs, stoppingToken);

dotnet/samples/SampleClient/RpcCommandRunner.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public class RpcCommandRunner(MqttSessionClient mqttClient, IServiceProvider ser
1515
{
1616
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
1717
{
18-
MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration!.GetConnectionString("Default")! + ";ClientId=sampleClient-" + Environment.TickCount);
18+
MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration!.GetConnectionString("Default")!);
1919

2020
await mqttClient.ConnectAsync(mcs, stoppingToken);
2121
await Console.Out.WriteLineAsync($"Connected to: {mcs}");

dotnet/samples/SessionClientConnectionManagementSample/LibraryManagedConnectionWorker.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ protected override async Task ExecuteAsync(CancellationToken cancellationToken)
1515
{
1616
sessionClient.SessionLostAsync += OnCrash;
1717
sessionClient.ApplicationMessageReceivedAsync += OnMessageReceived;
18-
MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration.GetConnectionString("Default")! + ";ClientId=LibraryManagedConnectionClient-" + Guid.NewGuid());
18+
MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration.GetConnectionString("Default")!);
1919

2020
await sessionClient.ConnectAsync(mcs, cancellationToken);
2121

dotnet/samples/UserManagedConnectionManagementSample/UserManagedConnectionWorker.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public class UserManagedConnectionWorker(OrderedAckMqttClient mqttClient, ILogge
1515

1616
protected override async Task ExecuteAsync(CancellationToken cancellationToken)
1717
{
18-
MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration.GetConnectionString("Default")! + ";ClientId=UserManagedConnectionClient-" + Guid.NewGuid());
18+
MqttConnectionSettings mcs = MqttConnectionSettings.FromConnectionString(configuration.GetConnectionString("Default")!);
1919

2020
mqttClient.ApplicationMessageReceivedAsync += OnMessageReceived;
2121
mqttClient.DisconnectedAsync += OnDisconnect;

0 commit comments

Comments
 (0)