module ActionPubsub::ActiveRecord::WithConnection