Skip to content

Commit f827e29

Browse files
[.NET][Akri] Remove placeholder client ids (#788)
These hardcoded client ids were just used while we waited on the Akri operator to deploy connectors with their actual client Ids.
1 parent 3d9ca04 commit f827e29

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

dotnet/samples/Connectors/EventDrivenTcpThermostatConnector/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
using Azure.Iot.Operations.Protocol;
77
using EventDrivenTcpThermostatConnector;
88

9-
string connectorClientId = Environment.GetEnvironmentVariable(ConnectorFileMountSettings.ConnectorClientIdEnvVar) ?? "todo";
9+
string connectorClientId = Environment.GetEnvironmentVariable(ConnectorFileMountSettings.ConnectorClientIdEnvVar) ?? throw new InvalidOperationException("No MQTT client Id configured by Akri operator");
1010

1111
IHost host = Host.CreateDefaultBuilder(args)
1212
.ConfigureServices(services =>

dotnet/samples/Connectors/PollingRestThermostatConnector/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
using Azure.Iot.Operations.Protocol;
77
using RestThermostatConnector;
88

9-
string connectorClientId = Environment.GetEnvironmentVariable(ConnectorFileMountSettings.ConnectorClientIdEnvVar) ?? "todo";
9+
string connectorClientId = Environment.GetEnvironmentVariable(ConnectorFileMountSettings.ConnectorClientIdEnvVar) ?? throw new InvalidOperationException("No MQTT client Id configured by Akri operator");
1010

1111
IHost host = Host.CreateDefaultBuilder(args)
1212
.ConfigureServices(services =>

dotnet/samples/Connectors/SqlConnector/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
using Azure.Iot.Operations.Protocol;
77
using SqlQualityAnalyzerConnectorApp;
88

9-
string connectorClientId = Environment.GetEnvironmentVariable(ConnectorFileMountSettings.ConnectorClientIdEnvVar) ?? "todo";
9+
string connectorClientId = Environment.GetEnvironmentVariable(ConnectorFileMountSettings.ConnectorClientIdEnvVar) ?? throw new InvalidOperationException("No MQTT client Id configured by Akri operator");
1010

1111
IHost host = Host.CreateDefaultBuilder(args)
1212

dotnet/src/Azure.Iot.Operations.Connector/Configurations/ConnectorFileMountSettings.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public class ConnectorFileMountSettings
2626
/// <returns>The instance of <see cref="MqttConnectionSettings"/> that allows the connector to connect to the MQTT broker.</returns>
2727
public static MqttConnectionSettings FromFileMount()
2828
{
29-
string clientId = Environment.GetEnvironmentVariable(ConnectorClientIdEnvVar) ?? "todo";
29+
string clientId = Environment.GetEnvironmentVariable(ConnectorClientIdEnvVar) ?? throw new InvalidOperationException("No MQTT client Id configured by Akri operator");
3030
string? brokerTrustBundleMountPath = Environment.GetEnvironmentVariable(BrokerTrustBundleMountPathEnvVar);
3131
string? brokerSatMountPath = Environment.GetEnvironmentVariable(BrokerSatMountPathEnvVar);
3232

0 commit comments

Comments
 (0)