class AliMns::Cli

Public Instance Methods

consume(name) click to toggle source
# File lib/ali_mns/cli.rb, line 23
def consume(name)
  execute("Consume 队列#{name}中的消息") do
    message = Queue[name].receive_message(wait_seconds: options[:wait])
    message.delete
    message
  end
end
create(name) click to toggle source
# File lib/ali_mns/cli.rb, line 17
def create(name)
  execute("创建消息队列'#{name}'"){ Queue[name].create }
end
delete(name) click to toggle source
# File lib/ali_mns/cli.rb, line 12
def delete(name)
  execute("删除消息队列'#{name}'"){ Queue[name].delete }
end
peek(name) click to toggle source
# File lib/ali_mns/cli.rb, line 37
def peek(name)
  execute("Peek 队列#{name}中的消息"){ Queue[name].peek_message }
end
queues() click to toggle source
# File lib/ali_mns/cli.rb, line 7
def queues()
  execute("消息队列列表"){ Queue.queues }
end
send(name, content) click to toggle source
# File lib/ali_mns/cli.rb, line 32
def send(name, content)
  execute("发送消息到#{name}队列"){ Queue[name].send_message content }
end

Private Instance Methods

execute(info=nil) { || ... } click to toggle source
# File lib/ali_mns/cli.rb, line 42
def execute info=nil
  begin
    puts info
    result = yield()
    puts result
  rescue RequestException => ex
    puts "#{ex['Code']}: #{ex['Message']}"
  end
  puts "\n"
end