Refactor produce_transactions in ESA::BlockingProcessor