class FakeServiceBus::MemoryDatabase

Public Class Methods

new() click to toggle source
# File lib/fake_servicebus/databases/memory.rb, line 11
def initialize
  @semaphore = Mutex.new
end

Public Instance Methods

load() click to toggle source
# File lib/fake_servicebus/databases/memory.rb, line 15
def load
  @queues = {}
end
reset() click to toggle source
# File lib/fake_servicebus/databases/memory.rb, line 25
def reset
  @queues = {}
end
transaction() { || ... } click to toggle source
# File lib/fake_servicebus/databases/memory.rb, line 19
def transaction
  @semaphore.synchronize do
    yield
  end
end