Class: Localjob::LinuxAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/localjob/linux_adapter.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name) ⇒ LinuxAdapter

Returns a new instance of LinuxAdapter.



16
17
18
 
# File 'lib/localjob/linux_adapter.rb', line 16

def initialize(name)
  @mqueue = POSIX::Mqueue.new(fix_queue_name(name))
end

Instance Attribute Details

#mqueue ⇒ Object (readonly)

Returns the value of attribute mqueue.



14
15
16
 
# File 'lib/localjob/linux_adapter.rb', line 14

def mqueue
  @mqueue
end

Instance Method Details

#destroy ⇒ Object 



32
33
34
 
# File 'lib/localjob/linux_adapter.rb', line 32

def destroy
  @mqueue.unlink
end

#receive ⇒ Object 



20
21
22
 
# File 'lib/localjob/linux_adapter.rb', line 20

def receive
  @mqueue.timedreceive
end

#send(message) ⇒ Object 



24
25
26
 
# File 'lib/localjob/linux_adapter.rb', line 24

def send(message)
  @mqueue.timedsend message
end

#size ⇒ Object 



28
29
30
 
# File 'lib/localjob/linux_adapter.rb', line 28

def size
  @mqueue.size
end

#to_io ⇒ Object 



36
37
38
 
# File 'lib/localjob/linux_adapter.rb', line 36

def to_io
  @mqueue.to_io
end