Module: RocketJob::Plugins::Transaction

Extended by:

ActiveSupport::Concern

Defined in:

lib/rocket_job/plugins/transaction.rb

Overview

Wraps every #perform call with an Active Record transaction / unit or work.

If the perform raises an exception it will cause any database changes to be rolled back.

For Batch Jobs the transaction is at the slice level so that the entire slice succeeds, or is rolled back.

Example:

# Update User and create an Audit entry as a single database transaction.
# If Audit.create! fails then the user change will also be rolled back.
class MyJob < RocketJob::Job
  include RocketJob::Plugins::Transaction

  def perform
    u = User.find(name: 'Jack')
    u.age = 21
    u.save!

    Audit.create!(table: 'user', description: 'Changed age to 21')
  end
end

Performance

• On CRuby an empty transaction block call takes about 1ms.

• On JRuby an empty transaction block call takes about 55ms.

Note:

• This plugin will only be activated if ActiveRecord has been loaded first.