Class: CelluloidIOPGListener::SuperviseSignature

Inherits:
Object
  • Object
show all
Defined in:
lib/celluloid-io-pg-listener/supervise_signature.rb

Overview

Usage:

Given a yaml config file of this format:

  listening_group:
  -
    listener_active: <%= ENV["LISTENER_ACTIVE"] || false %>
    type: HerokuConnectListener::SalesforceAccountClient
    as: insert_client
    args:
      database_url: <%= ENV["DATABASE_URL"] %>
        redis_url: <%= ENV["REDISTOGO_URL"] || "redis://localhost:6379/" %>
      callback_method: notify_callback
      channel: <%= ENV["SCHEMA_NAME"] %>_account_insert

Create a Supervision Container such as:

  class ListeningGroup < Celluloid::Supervision::Container
    config_path = options[:config_path] || "config/settings.yml"
    config      = YAML::load(ERB.new(File.read(config_path)).result)
    supervise CelluloidIOPGListener::SuperviseSignature.new(
                  type: config["type"],
                  as: config["as"],
                  args: config["args"]
              ).signature
  end

  ListeningGroup.run

Constant Summary collapse

KEYS_WITH_SYMBOL_VALUES = 
%( callback_method )

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(type:, as:, args:) ⇒ SuperviseSignature

Returns a new instance of SuperviseSignature.



37
38
39
40
41
42
43
44
45
 
# File 'lib/celluloid-io-pg-listener/supervise_signature.rb', line 37

def initialize(type:, as:, args:)
  @type = Kernel.const_get(type)
  @as = as.to_sym
  if has_database_url?(args)
    args.merge!(convert_database_url_to_hash(db_url: args.delete("database_url")))
  end
  @args = []
  @args << symbolize_keys(args)
end

Instance Attribute Details

#args ⇒ Object (readonly)

Returns the value of attribute args.



35
36
37
 
# File 'lib/celluloid-io-pg-listener/supervise_signature.rb', line 35

def args
  @args
end

#as ⇒ Object (readonly)

Returns the value of attribute as.



34
35
36
 
# File 'lib/celluloid-io-pg-listener/supervise_signature.rb', line 34

def as
  @as
end

#type ⇒ Object (readonly)

Returns the value of attribute type.



33
34
35
 
# File 'lib/celluloid-io-pg-listener/supervise_signature.rb', line 33

def type
  @type
end

Instance Method Details

#signature ⇒ Object 



47
48
49
50
51
52
53
 
# File 'lib/celluloid-io-pg-listener/supervise_signature.rb', line 47

def signature
  {
      type: type,
      as: as,
      args: args
  }
end