Module: Kyu::Postman::ClassMethods

Defined in:
lib/kyu/postman.rb

Instance Method Summary collapse

Instance Method Details

#error_callback(error_callback) ⇒ Object 



41
42
43
 
# File 'lib/kyu/postman.rb', line 41

def error_callback( error_callback )
  @error_callback = error_callback
end

#logger(logger) ⇒ Object 



37
38
39
 
# File 'lib/kyu/postman.rb', line 37

def logger( logger )
  @logger = logger
end

#queue_name(queue_name) ⇒ Object 



33
34
35
 
# File 'lib/kyu/postman.rb', line 33

def queue_name( queue_name )
  @queue_name = queue_name
end

#send_message(msg) ⇒ Object 



45
46
47
48
49
50
51
 
# File 'lib/kyu/postman.rb', line 45

def send_message( msg )
  raise 'Queue cannot be nil or empty' if @queue_name.nil? || @queue_name.empty?
  options = {}
  options.merge!( logger: @logger ) unless @logger.nil?
  options.merge!( error_callback: @error_callback ) unless @error_callback.nil?
  Postman.send_message( @queue_name, msg, options )
end