Relay needs to wait for response (#43)

xibosignage · Oct 17, 2023 · 0dd335d · 0dd335d
1 parent 06b8d87
commit 0dd335d
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/Worker.cs b/Worker.cs
@@ -267,12 +267,19 @@ Task Relay(CancellationToken stoppingToken)
  bool result = _relayQueue.TryTake(out string message, -1, stoppingToken);
  if (result && !string.IsNullOrEmpty(message))
  {
- _logger.LogDebug("Relay message");
  bool sendResult = relaySocket.TrySendFrame(message);
  if (!sendResult)
  {
  _logger.LogError("Unable to relay message");
  }
+
+ bool receiveResult = relaySocket.TryReceiveFrameString(TimeSpan.FromMilliseconds(500), out string sendReturn);
+ if (!receiveResult)
+ {
+ _logger.LogError("Unable to relay message, no response");
+ }
+
+ _logger.LogDebug("Relay message: {return}", sendReturn);
  }
  }