Update to try to send as well

novotnyllc · May 1, 2019 · b2b31ad · b2b31ad
1 parent f52282c
commit b2b31ad
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 1 deletion.
diff --git a/AppInsights.WindowsDesktop/PersistenceChannel/PersistenceChannel.cs b/AppInsights.WindowsDesktop/PersistenceChannel/PersistenceChannel.cs
@@ -218,11 +218,12 @@ public void Send(ITelemetry item)
         }
 
         /// <summary>
-        /// Flushes the in-memory buffer to disk. 
+        /// Flushes the in-memory buffer to disk. And attempt to send
         /// </summary>
         public void Flush()
         {   
             this.flushManager.Flush();
+            this.Transmitter.ForceImmediateSend();
         }        
     }
 }
diff --git a/AppInsights.WindowsDesktop/PersistenceChannel/PersistenceTransmitter.cs b/AppInsights.WindowsDesktop/PersistenceChannel/PersistenceTransmitter.cs
@@ -208,6 +208,15 @@ private void AcquireMutex(Action action)
             }
         }
 
+        public void ForceImmediateSend()
+        {
+            foreach (var sender in this.senders)
+            {
+                sender.ForceSendNow();
+            }
+        }
+
+
         /// <summary>
         /// Create senders to send telemetries. 
         /// </summary>

diff --git a/AppInsights.WindowsDesktop/PersistenceChannel/Sender.cs b/AppInsights.WindowsDesktop/PersistenceChannel/Sender.cs
@@ -134,6 +134,12 @@ public void Dispose()
             }
         }
 
+        internal void ForceSendNow()
+        {
+            // sets the delay handler to trigger an immediate sent
+            this.DelayHandler.Set();
+        }
+
         /// <summary>
         /// Stops the sender. 
         /// </summary>