Module: ZQ::Sources::TransactionalMixin

Included in:
RedisRPOPLPUSH
Defined in:
lib/zq/sources/mixins.rb

Instance Method Summary collapse

Instance Method Details

#transaction(&block) ⇒ Object 



13
14
15
16
17
18
19
20
21
 
# File 'lib/zq/sources/mixins.rb', line 13

def transaction(&block)
  item = self.read_next
  begin
    self.commit(item) if yield(item)
  rescue => error
    self.rollback(item)
    throw :exhausted # or raise ?
  end
end

#transactional? ⇒ Boolean

Returns:

  • (Boolean) 


9
10
11
 
# File 'lib/zq/sources/mixins.rb', line 9

def transactional?
  true
end