vendor/bundle/ruby/1.8/gems/activemessaging-0.9.0/lib/activemessaging/gateway.rb
def connection broker_name='default'
        return @@connections[broker_name] if @@connections.has_key?(broker_name)
        config = load_connection_configuration(broker_name)
        adapter_class = Gateway.adapters[config[:adapter]]
        raise "Unknown messaging adapter #{config[:adapter].inspect}!" if adapter_class.nil?
        @@connections[broker_name] = adapter_class.new(config)
      end
# Starts up an message listener to start polling for messages on each configured connection, and dispatching processing
Starts up an message listener to start polling for messages on each configured connection, and dispatching processing
Starts up an message listener to start polling for messages on each configured connection and dispatching processing
def connection broker_name='default'
        return @@connections[broker_name] if @@connections.has_key?(broker_name)
        config = load_connection_configuration(broker_name)
        adapter_class = Gateway.adapters[config[:adapter]]
        raise "Unknown messaging adapter #{config[:adapter].inspect}!" if adapter_class.nil?
        @@connections[broker_name] = adapter_class.new(config)
      end
def connection broker_name = 'default' return @@connections [ broker_name ] if @@connections . has_key? ( broker_name ) config = load_connection_configuration ( broker_name ) adapter_class = Gateway . adapters [ config [ :adapter ] ] raise "Unknown messaging adapter #{config[:adapter].inspect}!" if adapter_class . nil? @@connections [ broker_name ] = adapter_class . new ( config ) end
Starts up an message listener to start polling for messages on each configured connection, and dispatching processing
Starts up an message listener to start polling for messages on each configured connection and dispatching processing
broker_name