class ActiveMessaging::Adapters::Adapter::Queue
Queue class is used to keep track of the subscriptions It contains :
- name of the queue - options to use when getting from the queue - number of subscriptions
Attributes
get_options[RW]
name[RW]
nb_subscriptions[RW]
Public Class Methods
new(name, get_options)
click to toggle source
# File lib/activemessaging/adapters/wmq.rb, line 169 def initialize(name, get_options) @name, @get_options = name, get_options @nb_subscriptions = 0 end
Public Instance Methods
add_subscription()
click to toggle source
# File lib/activemessaging/adapters/wmq.rb, line 174 def add_subscription @nb_subscriptions += 1 end
has_subscription?()
click to toggle source
# File lib/activemessaging/adapters/wmq.rb, line 182 def has_subscription? @nb_subscriptions > 0 end
remove_subscription()
click to toggle source
# File lib/activemessaging/adapters/wmq.rb, line 178 def remove_subscription @nb_subscriptions -= 1 unless @nb_subscriptions > 0 end
to_s()
click to toggle source
# File lib/activemessaging/adapters/wmq.rb, line 186 def to_s "<Adapter::Queue name='#{@name}' get_options=#{@get_options} nb_subscriptions=#{@nb_subscriptions}>" end