Module: Cassieq::Client::Queues

Included in:
Cassieq::Client
Defined in:
lib/cassieq/client/queues.rb

Instance Method Summary collapse

Instance Method Details

#create_queue(options, error_if_exists = nil) ⇒ Object 



10
11
12
13
14
 
# File 'lib/cassieq/client/queues.rb', line 10

def create_queue(options, error_if_exists = nil)
  body = Cassieq::Utils.camelize_and_stringify_keys(options).to_json
  query = { errorIfExists: error_if_exists } unless error_if_exists.nil?
  request(:post, "queues", body, query)
end

#delete_queue(queue_name) ⇒ Object 



20
21
22
 
# File 'lib/cassieq/client/queues.rb', line 20

def delete_queue(queue_name)
  request(:delete, "queues/#{queue_name}")
end

#queue(queue_name) ⇒ Object 



16
17
18
 
# File 'lib/cassieq/client/queues.rb', line 16

def queue(queue_name)
  request(:get, "queues/#{queue_name}")
end

#queues ⇒ Object 



6
7
8
 
# File 'lib/cassieq/client/queues.rb', line 6

def queues
  request(:get, "queues")
end