Refactor MessageProcessor -> UnitOfWork
Do not execute operations for models which are not subscribed to
Transaction support on subscriber for ActiveRecord