Class: AliMns::Cli

Inherits:
Thor
  • Object
show all
Defined in:
lib/ali_mns/cli.rb

Instance Method Summary collapse

Instance Method Details

#consume(name) ⇒ Object 



23
24
25
26
27
28
29
 
# 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) ⇒ Object 



17
18
19
 
# File 'lib/ali_mns/cli.rb', line 17

def create(name)
  execute("创建消息队列'#{name}'"){ Queue[name].create }
end

#delete(name) ⇒ Object 



12
13
14
 
# File 'lib/ali_mns/cli.rb', line 12

def delete(name)
  execute("删除消息队列'#{name}'"){ Queue[name].delete }
end

#peek(name) ⇒ Object 



37
38
39
 
# File 'lib/ali_mns/cli.rb', line 37

def peek(name)
  execute("Peek 队列#{name}中的消息"){ Queue[name].peek_message }
end

#queues ⇒ Object 



7
8
9
 
# File 'lib/ali_mns/cli.rb', line 7

def queues()
  execute("消息队列列表"){ Queue.queues }
end

#send(name, content) ⇒ Object 



32
33
34
 
# File 'lib/ali_mns/cli.rb', line 32

def send(name, content)
  execute("发送消息到#{name}队列"){ Queue[name].send_message content }
end