Merge pull request #36 from Particular/stable-endpoint-instance-ids

Unique and stable instance ids

Author: tmasternak

Solution/Billing/Program.cs

@@ -28,11 +28,15 @@ static async Task Main()
                 .Delayed(delayed => delayed.NumberOfRetries(0));
 
             //endpointConfiguration.AuditProcessedMessagesTo("audit");
+
+            endpointConfiguration.UniquelyIdentifyRunningInstance()
+                .UsingCustomIdentifier(new Guid("1C62248E-2681-45A4-B44D-5CF93584BAD6"))
+                .UsingCustomDisplayName("original-instance");
+
             var metrics = endpointConfiguration.EnableMetrics();
             metrics.SendMetricDataToServiceControl(
                 "Particular.Monitoring", 
-                TimeSpan.FromMilliseconds(500),
-                "original-instance"
+                TimeSpan.FromMilliseconds(500)
             );
 
             var routing = transport.Routing();

Solution/ClientUI/Program.cs

@@ -23,11 +23,14 @@ static async Task Main()
             var transport = endpointConfiguration.UseTransport<SqlServerTransport>();
             transport.ConnectionStringName("NServiceBus/Transport");
 
+            endpointConfiguration.UniquelyIdentifyRunningInstance()
+                .UsingCustomIdentifier(new Guid("EA3E7D1B-8171-4098-B160-1FEA975CCB2C"))
+                .UsingCustomDisplayName("original-instance");
+
             var metrics = endpointConfiguration.EnableMetrics();
             metrics.SendMetricDataToServiceControl(
                 "Particular.Monitoring",
-                TimeSpan.FromMilliseconds(500),
-                "original-instance"
+                TimeSpan.FromMilliseconds(500)
             );
 
 

Solution/Sales/Program.cs

@@ -1,5 +1,7 @@
 using System;
 using System.Linq;
+using System.Security.Cryptography;
+using System.Text;
 using System.Threading.Tasks;
 using NServiceBus;
 using Shared;
@@ -14,18 +16,20 @@ static async Task Main(string[] args)
 
             LoggingUtils.ConfigureLogging("Sales");
 
-            var instanceIdentifier = args.FirstOrDefault();
-            if(string.IsNullOrEmpty(instanceIdentifier))
+            var instanceName = args.FirstOrDefault();
+
+            if(string.IsNullOrEmpty(instanceName))
             {
                 Console.Title = "Sales";
-                instanceIdentifier = "original-instance";
+
+                instanceName = "original-instance";
             }
             else
             {
-                Console.Title = $"Sales - {instanceIdentifier}";
+                Console.Title = $"Sales - {instanceName}";
             }
 
-            Console.WriteLine("Using instance-id {0}", instanceIdentifier);
+            var instanceId = DeterministicGuid.Create("Sales", instanceName);
 
             var endpointConfiguration = new EndpointConfiguration("Sales");
             endpointConfiguration.LimitMessageProcessingConcurrencyTo(4);
@@ -38,11 +42,14 @@ static async Task Main(string[] args)
 
             //endpointConfiguration.AuditProcessedMessagesTo("audit");
 
+            endpointConfiguration.UniquelyIdentifyRunningInstance()
+                .UsingCustomDisplayName(instanceName)
+                .UsingCustomIdentifier(instanceId);
+
             var metrics = endpointConfiguration.EnableMetrics();
             metrics.SendMetricDataToServiceControl(
                 "Particular.Monitoring",
-                TimeSpan.FromMilliseconds(500),
-                instanceIdentifier
+                TimeSpan.FromMilliseconds(500)
             );
 
             var simulationEffects = new SimulationEffects();
@@ -51,7 +58,7 @@ static async Task Main(string[] args)
             var endpointInstance = await Endpoint.Start(endpointConfiguration)
                 .ConfigureAwait(false);
 
-            RunUserInterfaceLoop(simulationEffects, instanceIdentifier);
+            RunUserInterfaceLoop(simulationEffects, instanceName);
 
             await endpointInstance.Stop()
                 .ConfigureAwait(false);
@@ -87,4 +94,19 @@ static void RunUserInterfaceLoop(SimulationEffects state, string instanceName)
             }
         }
     }
+
+    static class DeterministicGuid
+    {
+        public static Guid Create(params object[] data)
+        {
+            // use MD5 hash to get a 16-byte hash of the string
+            using (var provider = new MD5CryptoServiceProvider())
+            {
+                var inputBytes = Encoding.Default.GetBytes(string.Concat(data));
+                var hashBytes = provider.ComputeHash(inputBytes);
+                // generate a guid from the hash:
+                return new Guid(hashBytes);
+            }
+        }
+    }
 }

Solution/Shipping/Program.cs

@@ -27,11 +27,14 @@ static async Task Main()
 
             endpointConfiguration.AuditProcessedMessagesTo("audit");
 
+            endpointConfiguration.UniquelyIdentifyRunningInstance()
+                .UsingCustomIdentifier(new Guid("BB8A8BAF-4187-455E-AAD2-211CD43267CB"))
+                .UsingCustomDisplayName("original-instance");
+
             var metrics = endpointConfiguration.EnableMetrics();
             metrics.SendMetricDataToServiceControl(
                 "Particular.Monitoring",
-                TimeSpan.FromMilliseconds(500),
-                "original-instance"
+                TimeSpan.FromMilliseconds(500)
             );
 
             var routing = transport.Routing();