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