gistfile1.rb

class PostCallbacks
  def after_create
    MagicBus::PostStream.new(self, 'create').enqueue
  end

  def after_update
    MagicBus::PostStream.new(self, 'update').enqueue
  end

  def after_destroy
    MagicBus::PostStream.new(self, 'delete').enqueue
  end
end

module MagicBus
  class PostStream < Stream
    def enqueue
      LegacyProcessor.enqueue_for_topic(@record, @event)

      MagicBus.queue.push(
        PostActivityProcessor.new(@message)
      )
      MagicBus.queue.push(
        ElasticsearchIndexProcessor.new(@message)
      )
      MagicBus.queue.push(
        IntegrationsProcessor.new(@message)
      )
      MagicBus.queue.push(
        NotificationsProcessor.new(@message)
      )
      MagicBus.queue.push(
        StatsProcessor.new(@message)
      )
    end
  end
end