static void outputCDRRecs()

in DataGenerators/TelcoGeneratorCore/Program.cs [293:319]

20 lines of code
2 McCabe index (conditional complexity)


        static void outputCDRRecs(EventHubProducerClient producerClient, CDRrecord r)
        {
            //Console.WriteLine("RecordType,SystemIdentity,FileNum,SwitchNum,CallingNum,CallingIMSI,CalledNum,CalledIMSI,Date,Time,TimeType,CallPeriod,CallingCellID,CalledCellID,ServiceType");
            //Console.WriteLine(r);

            try
            {
                List<Task> tasks = new List<Task>();
                var serializedString = JsonConvert.SerializeObject(r);
                EventData data = new EventData(Encoding.UTF8.GetBytes(serializedString));
                SendEventOptions option = new SendEventOptions()
                {
                    PartitionKey = r.CallingIMSI
                };

                // Send the metric to Event Hub
                tasks.Add(producerClient.SendAsync(new List<EventData>() { data }, option));

                Console.WriteLine(r);

                Task.WaitAll(tasks.ToArray());
            }
            catch (Exception e)
            {
                Console.WriteLine("Error on send: " + e.Message);
            }
        }