class Aliyun::Mqs::Cli
Public Instance Methods
consume(name)
click to toggle source
# File lib/aliyun/mqs/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/aliyun/mqs/cli.rb, line 17 def create(name) execute("创建消息队列'#{name}'"){ Queue[name].create } end
delete(name)
click to toggle source
# File lib/aliyun/mqs/cli.rb, line 12 def delete(name) execute("删除消息队列'#{name}'"){ Queue[name].delete } end
peek(name)
click to toggle source
# File lib/aliyun/mqs/cli.rb, line 37 def peek(name) execute("Peek 队列#{name}中的消息"){ Queue[name].peek_message } end
queues()
click to toggle source
# File lib/aliyun/mqs/cli.rb, line 7 def queues() execute("消息队列列表"){ Queue.queues } end
send(name, content)
click to toggle source
# File lib/aliyun/mqs/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/aliyun/mqs/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