Class: Daemon::Messaging::Mailbox

Inherits:

Object

• Object
• Daemon::Messaging::Mailbox

show all

Defined in:

lib/onapp/engine/messaging/mailbox.rb

Overview

Instance Method Summary (collapse)

• - (Boolean) any?
• - (Mailbox) initialize(queue) constructor

  A new instance of Mailbox.

• - (Object) pop

  Removes message from PQueue.

• - (Object) size

  Messages count.

• - (Object) subscribe(&block)

  Add subscriber block.

15
16
17
18
19
20

# File 'lib/onapp/engine/messaging/mailbox.rb', line 15

def initialize(queue)
  @queue = queue
  @mailbox = Daemon::Utils::SharedValue.new(PQueue.new)
  @callbacks = Daemon::Utils::SharedValue.new([])
  subscribe_to_queue
end

40
41
42

# File 'lib/onapp/engine/messaging/mailbox.rb', line 40

def any?
  size > 0
end

23
24
25

# File 'lib/onapp/engine/messaging/mailbox.rb', line 23

def pop
  @mailbox.acquire(&:pop)
end

36
37
38

# File 'lib/onapp/engine/messaging/mailbox.rb', line 36

def size
  @mailbox.acquire(&:size)
end

29
30
31
32
33

# File 'lib/onapp/engine/messaging/mailbox.rb', line 29

def subscribe(&block)
  if block
    @callbacks.acquire { |c| c << block }
  end
end