gistfile1.cs

public void Publish(IEnumerable<Reservation> reservations, out int nextWaterMark)
{
    nextWaterMark = 0;

    using (IRabbitMqClient client = _clientFactory())
    {
        var channel = client.GetChannel();

        foreach (var reservation in reservations)
        {
            string routingKey = GetRoutingKey(reservation);
            string jsonReservation = SerializetoJson(reservation);
            byte[] messageBodyBytes = System.Text.Encoding.UTF8.GetBytes(jsonReservation);
            IBasicProperties props = GetBasicProperties(channel, routingKey, client.OtReservationExchange);

            channel.BasicPublish(client.OtReservationExchange, routingKey, false, false, props, messageBodyBytes);
              
            Analytics.Client.Track(
                reservation.gpId, 
                "reservation_made", 
                SerializetoDict(reservation);
                new Options().SetAnonymousId(anonymousId));
      
            ABclient.trackGoal(“reservation_made”, anonymousId); //anonymous unique visitor ID

            nextWaterMark = reservation.reservationSequenceNumber;
        }
    }
}