class TrRMIte::ProxyProducer

Attributes

queue[R]

Public Class Methods

new(queue_uri) click to toggle source
Calls superclass method TrRMIte::EventProducer::new
# File lib/TrRMIte/producer.rb, line 76
def initialize(queue_uri)
  super
  @queue = Queue.new
end

Private Instance Methods

next_event() click to toggle source
# File lib/TrRMIte/producer.rb, line 83
def next_event
  @queue.pop
end