LoanQuoteSubmissionPipe.cs

public class QueueBackedLoanQuoteSubmissionPipe
        : IPipe<EnrichedLoanRequest>
{
    // this is just a simple helper library I wrote
    private readonly SimpleQueueHelper queueHelper;

    public QueueBackedLoanQuoteSubmissionPipe(
        SimpleQueueHelper queueHelper)
    {
        this.queueHelper = queueHelper;
    }

    public async Task Write(EnrichedLoanRequest payload)
    {
        await queueHelper.SendMessage(payload);        
    }
}