class QRPC::Locator::EventedQueueLocator

Locator for ‘evented-queue’ queue type.

@see github.com/martinkozak/evented-queue @since 0.9.0

Attributes

input_queue[RW]

Contains queue instance. @return [EventedQueue::Recurring]

output_queue[RW]

Contains queue instance. @return [EventedQueue::Recurring]

queue[RW]

Contains queue instance. @return [EventedQueue::Recurring]

queue_name[RW]

Contains queue name. @return [String]

Public Class Methods

new(queue_name, queue = self.default_queue) click to toggle source

Constructor. @param [EventedQueue::Recurring] queue recurring evented queue instance

# File lib/qrpc/locator/evented-queue.rb, line 52
def initialize(queue_name, queue = self.default_queue)
    @queue = queue
    @queue_name = queue_name
end

Public Instance Methods

default_queue() click to toggle source

Returns the default evented queue type.

# File lib/qrpc/locator/evented-queue.rb, line 61
def default_queue 
    UnifiedQueues::Multi::new UnifiedQueues::Single, ::EM::Wrapper::new(REUQ),  UnifiedQueues::Single, CPriorityQueue
end