in DataGenerators/SensorEventGenerator/SensorEventGenerator/EventHubObserver.cs [46:69]
public void OnNext(Sensor sensorData)
{
try
{
var serialisedString = JsonConvert.SerializeObject(sensorData);
EventData data = new EventData(Encoding.UTF8.GetBytes(serialisedString)) { PartitionKey = sensorData.dspl };
_eventHubClient.Send(data);
Console.ForegroundColor = ConsoleColor.Yellow;
Console.WriteLine("Sending" + serialisedString + " at: " + sensorData.time);
//To write every event entry to the logfile, uncomment the line below.
//Note: Writing every event can quickly grow the size of the log file.
//_logger.Write("Sending" + serialisedString + " at: " + sensorData.TimeStamp);
}
catch (Exception ex)
{
_logger.Write(ex);
throw ex;
}
}