Class: RubyHaze::Queue

Inherits:
Object
  • Object
show all
Includes:
Mixins::DOProxy
Defined in:
lib/rubyhaze/queue.rb

Instance Attribute Summary

Attributes included from Mixins::DOProxy

#name

Attributes included from Mixins::Proxy

#proxy_object

Instance Method Summary collapse

Methods included from Mixins::DOProxy

included

Methods included from Mixins::NativeException

#rescue_native_exception

Methods included from Mixins::Compare

#==

Methods included from Mixins::Proxy

included, #method_missing, #respond_to?

Constructor Details

#initialize(name) ⇒ Queue

Returns a new instance of Queue.



7
8
9
10
 
# File 'lib/rubyhaze/queue.rb', line 7

def initialize(name)
  @name = name.to_s
  @proxy_object = Hazelcast.get_queue @name
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method in the class RubyHaze::Mixins::Proxy

Instance Method Details

#poll(timeout = 5, unit = :seconds) ⇒ Object 



12
13
14
 
# File 'lib/rubyhaze/queue.rb', line 12

def poll(timeout = 5, unit = :seconds)
  @proxy_object.poll timeout, java.util.concurrent.TimeUnit.const_get(unit.to_s.upcase)
end