Module: Ocular::Inputs::RabbitMQ::DSL

Included in:

Event::DefinitionProxy

Defined in:

lib/ocular/inputs/rabbitmq_input.rb

Instance Method Summary

• #rabbitmq ⇒ Object

  add_event_help “cron.in(rule)”, “Schedule event to be executed in ‘rule’.

Instance Method Details

#rabbitmq ⇒ Object

add_event_help “cron.in(rule)”, “Schedule event to be executed in ‘rule’. eg: ‘1m’”

# File 'lib/ocular/inputs/rabbitmq_input.rb', line 15

def rabbitmq()
    handler = handlers.get(::Ocular::Inputs::RabbitMQ::Input)
    return Input::DSLProxy.new(self, handler, logger)
end