Reset the settings timer when we actually talk to the server.

Author: ejsmith

Source/Shared/ExceptionlessClient.cs

@@ -39,7 +39,13 @@ public ExceptionlessClient(ExceptionlessConfiguration configuration) {
             _queue = new Lazy<IEventQueue>(() => {
                 // config can't be changed after the queue starts up.
                 Configuration.LockConfig();
-                return Configuration.Resolver.GetEventQueue();
+
+                var q = Configuration.Resolver.GetEventQueue();
+                q.EventsPosted += (sender, args) => {
+                    _updateSettingsTimer.Change(Configuration.UpdateSettingsWhenIdleInterval, Configuration.UpdateSettingsWhenIdleInterval);
+                };
+
+                return q;
             });
 
             _submissionClient = new Lazy<ISubmissionClient>(() => Configuration.Resolver.GetSubmissionClient());
@@ -181,7 +187,6 @@ public void SubmitEvent(Event ev, ContextData pluginContextData = null) {
             }
 
             OnSubmittedEvent(new EventSubmittedEventArgs(this, ev, pluginContextData));
-            _updateSettingsTimer.Change(Configuration.UpdateSettingsWhenIdleInterval, Configuration.UpdateSettingsWhenIdleInterval);
         }
 
         /// <summary>Creates a new instance of <see cref="Event" />.</summary>

Source/Shared/Queue/DefaultEventQueue.cs

@@ -71,7 +71,8 @@ public void Process() {
                     bool deleteBatch = true;
 
                     try {
-                        var response = _client.PostEvents(batch.Select(b => b.Item2), _config, _serializer);
+                        var events = batch.Select(b => b.Item2).ToList();
+                        var response = _client.PostEvents(events, _config, _serializer);
                         if (response.Success) {
                             _log.FormattedInfo(typeof(DefaultEventQueue), "Sent {0} events to \"{1}\".", batch.Count, _config.ServerUrl);
                         } else if (response.ServiceUnavailable) {
@@ -104,6 +105,8 @@ public void Process() {
                             SuspendProcessing();
                             deleteBatch = false;
                         }
+
+                        OnEventsPosted(new EventsPostedEventArgs { Events = events, Response = response });
                     } catch (AggregateException ex) {
                         _log.Error(typeof(DefaultEventQueue), ex, String.Concat("An error occurred while submitting events: ", ex.Flatten().Message));
                         SuspendProcessing();
@@ -162,6 +165,12 @@ public void SuspendProcessing(TimeSpan? duration = null, bool discardFutureQueue
             } catch (Exception) { }
         }
 
+        public event EventHandler<EventsPostedEventArgs> EventsPosted;
+
+        protected virtual void OnEventsPosted(EventsPostedEventArgs e) {
+            EventsPosted?.Invoke(this, e);
+        }
+
         private bool IsQueueProcessingSuspended {
             get { return _suspendProcessingUntil.HasValue && _suspendProcessingUntil.Value > DateTime.Now; }
         }

Source/Shared/Queue/IEventQueue.cs

@@ -1,11 +1,19 @@
 using System;
+using System.Collections.Generic;
 using System.Threading.Tasks;
 using Exceptionless.Models;
+using Exceptionless.Submission;
 
 namespace Exceptionless.Queue {
     public interface IEventQueue : IDisposable {
         void Enqueue(Event ev);
         Task ProcessAsync();
         void SuspendProcessing(TimeSpan? duration = null, bool discardFutureQueuedItems = false, bool clearQueue = false);
+        event EventHandler<EventsPostedEventArgs> EventsPosted;
+    }
+
+    public class EventsPostedEventArgs : EventArgs {
+        public SubmissionResponse Response { get; set; }
+        public ICollection<Event> Events { get; set; }
     }
 }