module Kyu::Postman::ClassMethods

Public Instance Methods

error_callback( error_callback ) click to toggle source
# File lib/kyu/postman.rb, line 41
def error_callback( error_callback )
  @error_callback = error_callback
end
logger( logger ) click to toggle source
# File lib/kyu/postman.rb, line 37
def logger( logger )
  @logger = logger
end
queue_name( queue_name ) click to toggle source
# File lib/kyu/postman.rb, line 33
def queue_name( queue_name )
  @queue_name = queue_name
end
send_message( msg ) click to toggle source
# 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