Telemetry

1 files changed, 7 insertions, 7 deletions

diff --git a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisherAdvanced.cs b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisherAdvanced.cs
index 2d0f48126..0183de6c2 100644
--- a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisherAdvanced.cs
+++ b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisherAdvanced.cs
@@ -15,7 +15,7 @@ namespace Tango.Telemetry
         /// </summary>
         public TimeSpan MaxExponentialBackoff { get; set; } = TimeSpan.FromHours(1);
 
-        public TelemetryPublisherAdvanced(IMachineOperator machineOperator, ITelemetryPendingStorageManager storageManager, TelemetryPublisherConfiguration config) : base(machineOperator, storageManager, config)
+        public TelemetryPublisherAdvanced(ITelemetryStorageManager storageManager, ITelemetryQueueManager queueManager, TelemetryPublisherConfiguration config) : base(storageManager, queueManager, config)
         {
 
         }
@@ -30,12 +30,12 @@ namespace Tango.Telemetry
             };
 
             var now = DateTime.UtcNow;
-            var pendingDestinations = package.TelemetryObject.PendingDestinations.ToList();
+            var pendingDestinations = package.PendingTelemetry.PendingDestinations.ToList();
 
             // For Streaming/External: initialize pending destinations list (used if publishing fails)
             if (package.Source == TelemetrySource.Streaming || package.Source == TelemetrySource.ExternalStorage)
             {
-                foreach (var dest in Config.TelemetryDestinations)
+                foreach (var dest in Destinations)
                 {
                     if (!pendingDestinations.Any(x => x.Name == dest.Name))
                     {
@@ -50,7 +50,7 @@ namespace Tango.Telemetry
                 }
             }
 
-            foreach (var destination in Config.TelemetryDestinations.Where(x => x.SupportedSources.Contains(package.Source)))
+            foreach (var destination in Destinations.Where(x => x.SupportedSources.Contains(package.Source)))
             {
                 var pendingEntry = pendingDestinations.FirstOrDefault(x => x.Name == destination.Name);
 
@@ -101,15 +101,15 @@ namespace Tango.Telemetry
                 }
             }
 
-            package.TelemetryObject.PendingDestinations = new List<TelemetryPendingDestination>(pendingDestinations);
+            package.PendingTelemetry.PendingDestinations = new List<TelemetryPendingDestination>(pendingDestinations);
 
             if (package.Source == TelemetrySource.PendingStorage && !pendingDestinations.Any())
             {
-                PendingStorageManager.DeleteTelemetryObject(package.TelemetryObject);
+                StorageManager.DeletePendingTelemetry(package.PendingTelemetry);
             }
             else
             {
-                PendingStorageManager.InsertOrUpdateTelemetryObject(package.TelemetryObject);
+                StorageManager.DeletePendingTelemetry(package.PendingTelemetry);
             }
         }
     }