Class: Qwirk::Adapter::ActiveMQ::WorkerConfig

Inherits:
JMS::WorkerConfig
  • Object
show all
Defined in:
lib/qwirk/adapter/active_mq/worker_config.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.in_process?(config) ⇒ Boolean

Returns:

  • (Boolean) 


6
7
8
9
 
# File 'lib/qwirk/adapter/active_mq/worker_config.rb', line 6

def self.in_process?(config)
  broker_url = config[:broker_url]
  return !!(broker_url && broker_url.start_with?('vm://'))
end

Instance Method Details

#init ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/qwirk/adapter/active_mq/worker_config.rb', line 11

def init
  if self.topic_name
    self.queue_name = "Consumer.#{self.name}.VirtualTopic.#{topic_name}"
    self.topic_name = nil
  end
  super
end