Module: Journaled::Connection

Includes:
TestOnlyBehaviors
Defined in:
lib/journaled/connection.rb

Defined Under Namespace

Modules: TestOnlyBehaviors

Class Method Summary collapse

Methods included from TestOnlyBehaviors

#transaction_open?

Class Method Details

.available?Boolean

Returns:

  • (Boolean)


6
7
8
# File 'lib/journaled/connection.rb', line 6

def available?
  Journaled.transactional_batching_enabled? && transaction_open?
end

.stage!(event) ⇒ Object



10
11
12
13
14
15
16
# File 'lib/journaled/connection.rb', line 10

def stage!(event)
  raise TransactionSafetyError, <<~MSG unless available?
    Transaction not available! By default, journaled event batching requires an open database transaction.
  MSG

  connection.current_transaction._journaled_staged_events << event
end