class Messaging::MessageRegistry

Public Instance Methods

get(message_name) click to toggle source
# File lib/messaging/message_registry.rb, line 17
def get(message_name)
  message_classes.find do |message_class|
    message_class.message_name == message_name
  end
end
length() click to toggle source
# File lib/messaging/message_registry.rb, line 42
def length
  message_classes.length
end
message_classes() click to toggle source
# File lib/messaging/message_registry.rb, line 7
def message_classes
  @message_classes ||= []
end
message_types() click to toggle source
# File lib/messaging/message_registry.rb, line 11
def message_types
  message_classes.map do |message_class|
    message_class.message_type
  end
end
register(message_class) click to toggle source
# File lib/messaging/message_registry.rb, line 23
def register(message_class)
  logger.trace { "Registering #{message_class}"}
  if registered?(message_class)
    error_msg = "#{message_class} is already registered"
    logger.error { error_msg }
    raise Error, error_msg
  end

  message_classes << message_class

  logger.debug { "Registered #{message_class}"}

  message_classes
end
registered?(message_class) click to toggle source
# File lib/messaging/message_registry.rb, line 38
def registered?(message_class)
  message_classes.include?(message_class)
end