Module: EventQ

Defined in:
lib/eventq/aws.rb,
lib/eventq/base.rb,
lib/eventq/rabbitmq.rb,
lib/eventq/queue_worker.rb,
lib/eventq/worker_status.rb,
lib/eventq/eventq_aws/sns.rb,
lib/eventq/eventq_aws/sqs.rb,
lib/eventq/eventq_base/queue.rb,
lib/eventq/eventq_base/exchange.rb,
lib/eventq/eventq_base/worker_id.rb,
lib/eventq/eventq_base/message_args.rb,
lib/eventq/eventq_base/configuration.rb,
lib/eventq/eventq_base/eventq_logger.rb,
lib/eventq/eventq_base/nonce_manager.rb,
lib/eventq/eventq_base/queue_message.rb,
lib/eventq/eventq_aws/aws_queue_client.rb,
lib/eventq/eventq_aws/aws_queue_worker.rb,
lib/eventq/eventq_aws/aws_eventq_client.rb,
lib/eventq/eventq_aws/aws_queue_manager.rb,
lib/eventq/eventq_aws/aws_status_checker.rb,
lib/eventq/eventq_rabbitmq/default_queue.rb,
lib/eventq/eventq_base/event_raised_queue.rb,
lib/eventq/eventq_base/signature_providers.rb,
lib/eventq/eventq_base/event_raised_exchange.rb,
lib/eventq/eventq_base/queue_worker_contract.rb,
lib/eventq/eventq_base/eventq_client_contract.rb,
lib/eventq/eventq_aws/aws_subscription_manager.rb,
lib/eventq/eventq_base/serialization_providers.rb,
lib/eventq/eventq_rabbitmq/rabbitmq_queue_client.rb,
lib/eventq/eventq_rabbitmq/rabbitmq_queue_worker.rb,
lib/eventq/eventq_rabbitmq/rabbitmq_eventq_client.rb,
lib/eventq/eventq_rabbitmq/rabbitmq_queue_manager.rb,
lib/eventq/eventq_rabbitmq/rabbitmq_status_checker.rb,
lib/eventq/eventq_base/subscription_manager_contract.rb,
lib/eventq/eventq_base/exceptions/worker_thread_error.rb,
lib/eventq/eventq_aws/aws_calculate_visibility_timeout.rb,
lib/eventq/eventq_base/exceptions/event_type_not_found.rb,
lib/eventq/eventq_rabbitmq/rabbitmq_subscription_manager.rb,
lib/eventq/eventq_base/exceptions/invalid_signature_exception.rb,
lib/eventq/eventq_base/signature_providers/sha256_signature_provider.rb,
lib/eventq/eventq_base/serialization_providers/oj_serialization_provider.rb,
lib/eventq/eventq_base/serialization_providers/json_serialization_provider.rb,
lib/eventq/eventq_base/serialization_providers/binary_serialization_provider.rb

Defined Under Namespace

Modules: Amazon, Exceptions, RabbitMq, SerializationProviders, SignatureProviders, WorkerId Classes: Configuration, EventQClientContract, EventRaisedExchange, EventRaisedQueue, Exchange, MessageArgs, NonceManager, Queue, QueueMessage, QueueWorker, QueueWorkerContract, SubscriptionManagerContract, WorkerProcess, WorkerStatus, WorkerThread

Class Method Summary collapse

Class Method Details

.create_event_type(event_type) ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/eventq/base.rb', line 10

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) ⇒ Object 



13
14
15
 
# File 'lib/eventq/rabbitmq.rb', line 13

def self.create_exchange_name(exchange)
  create_queue_name(exchange)
end

.create_queue_name(queue) ⇒ Object 



17
18
19
20
21
22
 
# File 'lib/eventq/base.rb', line 17

def self.create_queue_name(queue)
  return queue.name if EventQ.namespace == nil

  delimiter = queue.namespace_delimiter || '-'
  return "#{EventQ.namespace}#{delimiter}#{queue.name}"
end

.log(type, message) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/eventq/eventq_base/eventq_logger.rb', line 13

def self.log(type, message)
  case type
    when :info
      logger.info(message)
    when :debug
      logger.debug(message)
    when :error
      logger.error(message)
  end
rescue
  #do nothing
end

.logger ⇒ Object 



5
6
7
 
# File 'lib/eventq/eventq_base/eventq_logger.rb', line 5

def self.logger
  return @@logger
end

.namespace ⇒ Object 



2
3
4
 
# File 'lib/eventq/base.rb', line 2

def self.namespace
  @namespace
end

.namespace=(value) ⇒ Object 



6
7
8
 
# File 'lib/eventq/base.rb', line 6

def self.namespace=(value)
  @namespace = value
end

.set_logger(logger) ⇒ Object 



9
10
11
 
# File 'lib/eventq/eventq_base/eventq_logger.rb', line 9

def self.set_logger(logger)
  @@logger = logger
end