Module: EventQ
- Defined in:
- lib/eventq_rabbitmq.rb,
lib/eventq_rabbitmq/default_queue.rb,
lib/eventq_rabbitmq/rabbitmq_queue_client.rb,
lib/eventq_rabbitmq/rabbitmq_queue_worker.rb,
lib/eventq_rabbitmq/rabbitmq_eventq_client.rb,
lib/eventq_rabbitmq/rabbitmq_queue_manager.rb,
lib/eventq_rabbitmq/rabbitmq_status_checker.rb,
lib/eventq_rabbitmq/rabbitmq_queue_worker_v2.rb,
lib/eventq_rabbitmq/jruby/rabbitmq_queue_worker.rb,
lib/eventq_rabbitmq/rabbitmq_subscription_manager.rb
Defined Under Namespace
Modules: RabbitMq
Class Method Summary collapse
- .create_event_type(event_type) ⇒ Object
- .create_exchange_name(exchange_name) ⇒ Object
- .create_queue_name(queue_name) ⇒ Object
- .namespace ⇒ Object
- .namespace=(value) ⇒ Object
Class Method Details
.create_event_type(event_type) ⇒ Object
32 33 34 35 36 37 |
# File 'lib/eventq_rabbitmq.rb', line 32 def self.create_event_type(event_type) if EventQ.namespace == nil return event_type end return "#{EventQ.namespace}-#{event_type}" end |
.create_exchange_name(exchange_name) ⇒ Object
44 45 46 47 48 49 |
# File 'lib/eventq_rabbitmq.rb', line 44 def self.create_exchange_name(exchange_name) if EventQ.namespace == nil return exchange_name end return "#{EventQ.namespace}-#{exchange_name}" end |
.create_queue_name(queue_name) ⇒ Object
38 39 40 41 42 43 |
# File 'lib/eventq_rabbitmq.rb', line 38 def self.create_queue_name(queue_name) if EventQ.namespace == nil return queue_name end return "#{EventQ.namespace}-#{queue_name}" end |
.namespace ⇒ Object
26 27 28 |
# File 'lib/eventq_rabbitmq.rb', line 26 def self.namespace @namespace end |
.namespace=(value) ⇒ Object
29 30 31 |
# File 'lib/eventq_rabbitmq.rb', line 29 def self.namespace=(value) @namespace = value end |