BlogStreamInsightAustin02

gistfile1.cs

public void OnNext(PointEvent<TEvent> e)
{
    if (e.EventKind == EventKind.Cti)
    {
        return;
    }

    var entity = e.Payload;

    try
    {
        _sqlConnection.Open();
        _sqlConnection.Insert(entity);
    }
    finally
    {
        _sqlConnection.Close();
    }
}