ckimball

        /// <summary>
        /// Attempt to process the RabbitMQ message for the subscriber notification
        /// </summary>
        /// <param name="message"></param>
        /// <param name="retryCount"></param>
        /// <returns></returns>
        private IoEither<Failure, Unit> ProcessMessage(IConsumeContext<ProcessSubscriberNotification> message, int retryCount)
        {
            Func<IConsumeContext<ProcessSubscriberNotification>, string, int, IoEither<Failure, Unit>> delayMessageProcessing = (m, log, delay) =>
                from _0 in Logger.DebugU($"STI Subscriber Notification Handler: {log}. Will retry after a delay of {delay} milliseconds.").ToIoEither<Failure, Unit>()