Restructure to use message_broker_producer_production_insert()