Allow Devices file to override Http Client Probe in MQTT Gateway Agents

TrakHound · Nov 2, 2023 · e6238a6 · e6238a6
1 parent b2cf403
commit e6238a6
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/src/MTConnect.NET-Applications-Agents-MQTT/MTConnectMqttBrokerAgentGatewayApplication.cs b/src/MTConnect.NET-Applications-Agents-MQTT/MTConnectMqttBrokerAgentGatewayApplication.cs
@@ -104,11 +104,15 @@ protected override void OnStartAgentBeforeLoad(IEnumerable<DeviceConfiguration>
                         agentClient.OnClientStopped += (s, e) => AgentClientStopped(agentClient);
                         agentClient.OnStreamStarted += (s, query) => AgentClientStreamStarted(agentClient, query);
                         agentClient.OnStreamStopped += (s, e) => AgentClientStreamStopped(agentClient);
-                        agentClient.OnProbeReceived += (s, doc) => DevicesDocumentReceived(agentClient, doc);
                         agentClient.OnCurrentReceived += (s, doc) => StreamsDocumentReceived(agentClient, doc);
                         agentClient.OnSampleReceived += (s, doc) => StreamsDocumentReceived(agentClient, doc);
                         agentClient.OnAssetsReceived += (s, doc) => AssetsDocumentReceived(agentClient, doc);
 
+                        if (Agent.GetDevice(agentClient.Device) == null)
+                        {
+                            agentClient.OnProbeReceived += (s, doc) => DevicesDocumentReceived(agentClient, doc);
+                        }
+
                         _clients.Add(agentClient);
                     }
                 }

diff --git a/src/MTConnect.NET-Applications-Agents-MQTT/MTConnectMqttRelayAgentGatewayApplication.cs b/src/MTConnect.NET-Applications-Agents-MQTT/MTConnectMqttRelayAgentGatewayApplication.cs
@@ -104,11 +104,15 @@ protected override void OnStartAgentBeforeLoad(IEnumerable<DeviceConfiguration>
                         agentClient.OnClientStopped += (s, e) => AgentClientStopped(agentClient);
                         agentClient.OnStreamStarted += (s, query) => AgentClientStreamStarted(agentClient, query);
                         agentClient.OnStreamStopped += (s, e) => AgentClientStreamStopped(agentClient);
-                        agentClient.OnProbeReceived += (s, doc) => DevicesDocumentReceived(agentClient, doc);
                         agentClient.OnCurrentReceived += (s, doc) => StreamsDocumentReceived(agentClient, doc);
                         agentClient.OnSampleReceived += (s, doc) => StreamsDocumentReceived(agentClient, doc);
                         agentClient.OnAssetsReceived += (s, doc) => AssetsDocumentReceived(agentClient, doc);
 
+                        if (Agent.GetDevice(agentClient.Device) == null)
+                        {
+                            agentClient.OnProbeReceived += (s, doc) => DevicesDocumentReceived(agentClient, doc);
+                        }
+
                         _clients.Add(agentClient);
                     }
                 }