diff --git a/essentials-framework/Essentials Core/PepperDashEssentialsBase/Queues/GenericQueue.cs b/essentials-framework/Essentials Core/PepperDashEssentialsBase/Queues/GenericQueue.cs
index a1cef30d..8dca9803 100644
--- a/essentials-framework/Essentials Core/PepperDashEssentialsBase/Queues/GenericQueue.cs
+++ b/essentials-framework/Essentials Core/PepperDashEssentialsBase/Queues/GenericQueue.cs
@@ -118,7 +118,7 @@ namespace PepperDash.Essentials.Core.Queues
///
public GenericQueue(string key, int pacing, Thread.eThreadPriority priority, int capacity)
: this(key, priority, capacity, pacing)
- {
+ {
}
///
diff --git a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs
index 1a9dec0e..edcc61ec 100644
--- a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs
+++ b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs
@@ -2529,12 +2529,9 @@ ConnectorID: {2}"
{
while (InitialSyncComplete)
{
- if (!_commandQueue.IsEmpty)
- {
- var query = _commandQueue.Dequeue();
+ var query = _commandQueue.Dequeue();
- _parent.SendText(query);
- }
+ _parent.SendText(query);
}
}
@@ -2596,7 +2593,11 @@ ConnectorID: {2}"
InitialSyncComplete = true;
Debug.Console(1, this, "Initial Codec Sync Complete!");
Debug.Console(1, this, "{0} Command queued. Processing now...", _commandQueue.Count);
- ProcessQueuedCommands();
+
+ // Invoke a thread for the queue
+ CrestronInvoke.BeginInvoke((o) => {
+ ProcessQueuedCommands();
+ });
}
else
InitialSyncComplete = false;