Sha256: a1acdf5b024b44aa71d4e148a63d8148bb5459386b13f1736dcad0813da29e9a

Contents?: true

Size: 1.34 KB

Versions: 4

Compression:

Stored size: 1.34 KB

Contents

if( config = DaemonKit.arguments.options[:configuration_file])
  load config if File.exist?(config)
end

if (source_uri = DaemonKit.arguments.options[:source_uri])
  Bunnicula.victim(source_uri)
end

if (DaemonKit.arguments.options[:targets])
  DaemonKit.logger.debug("Target options from commandline:#{DaemonKit.arguments.options[:targets].inspect}")
  targets = DaemonKit.arguments.options[:targets]
  targets.each do |target_config|
    Bunnicula.transfusion_to(target_config[:target_uri]) do |vamp|
      target_config[:relays].each do |relay_config|
        vamp.relay do |r|
          from_options = {}
          from_options[:durable] = relay_config[:from_durable] if relay_config[:from_durable]
          from_options[:ack] = relay_config[:from_ack] if relay_config[:from_ack]
          from_options[:type] = relay_config[:from_type] if relay_config[:from_type]
          r.from relay_config[:from], from_options
          if (to_exchange = relay_config[:to])
            to_options = {}
            to_options[:durable] = relay_config[:to_durable] if relay_config[:to_durable]
            to_options[:ack] = relay_config[:to_ack] if relay_config[:to_ack]
            to_options[:type] = relay_config[:to_type] if relay_config[:to_type]
            r.to to_exchange, to_options
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
bunnicula-0.2.2 config/post-daemonize/configure_bunnicula.rb
bunnicula-0.2.1 config/post-daemonize/configure_bunnicula.rb
bunnicula-0.2.0 config/post-daemonize/configure_bunnicula.rb
bunnicula-0.1.1 config/post-daemonize/configure_bunnicula.rb