diff --git a/ViscaLibrary/ViscaProtocolProcessor.cs b/ViscaLibrary/ViscaProtocolProcessor.cs index f4673ce..5d07df2 100644 --- a/ViscaLibrary/ViscaProtocolProcessor.cs +++ b/ViscaLibrary/ViscaProtocolProcessor.cs @@ -44,7 +44,7 @@ public static T Dequeue(this BlockingCollection queue) } #endif - public class ViscaProtocolProcessor + public class ViscaProtocolProcessor : IDisposable { private readonly Dictionary _cameras = new Dictionary(7); @@ -118,13 +118,13 @@ public ViscaProtocolProcessor(Action sendData, Action /// Commands in the sending queue @@ -324,6 +324,11 @@ private void parseResponse(object obj) logMessage(2, "Visca Response Queue shutdown"); break; } + catch (InvalidOperationException) + { + logMessage(2, "Visca Response Queue shutdown 2"); + break; + } #endif catch (Exception e) {