test/integration/service_bus/queues_test.rb in azure-0.6.4 vs test/integration/service_bus/queues_test.rb in azure-0.7.0.pre
- old
+ new
@@ -15,11 +15,11 @@
require "integration/test_helper"
describe "ServiceBus Queues" do
subject { Azure::ServiceBus::ServiceBusService.new }
- let(:name) { ServiceBusQueueNameHelper.name }
+ let(:queue_name) { ServiceBusQueueNameHelper.name }
let(:name_alternative) { ServiceBusQueueNameHelper.name }
let(:description) {{
:default_message_time_to_live => 'P10675199DT2H48M5.4775807S',
:duplicate_detection_history_time_window => 'PT10M',
:dead_lettering_on_message_expiration => "false",
@@ -42,19 +42,19 @@
}}
after { ServiceBusQueueNameHelper.clean }
it "should be able to create a new queue from a string" do
- queue = subject.create_queue name
+ queue = subject.create_queue queue_name
queue.must_be_kind_of Azure::ServiceBus::Queue
- queue.name.must_equal name
+ queue.name.must_equal queue_name
end
it "should be able to create a new queue from a Queue" do
- queue = subject.create_queue Azure::ServiceBus::Queue.new(name)
+ queue = subject.create_queue Azure::ServiceBus::Queue.new(queue_name)
queue.must_be_kind_of Azure::ServiceBus::Queue
- queue.name.must_equal name
+ queue.name.must_equal queue_name
end
it "should be able to create a new queue from a string and description Hash" do
queue = subject.create_queue name_alternative, description_alternative
queue.must_be_kind_of Azure::ServiceBus::Queue
@@ -86,31 +86,31 @@
queue.max_delivery_count.must_equal description_alternative[:max_delivery_count]
queue.enable_batched_operations.must_equal description_alternative[:enable_batched_operations]
end
describe 'when a queue exists' do
- before { subject.create_queue name }
+ before { subject.create_queue queue_name }
describe '#delete_queue' do
it "should raise exception if the queue cannot be deleted" do
assert_raises(Azure::Core::Http::HTTPError) do
subject.delete_queue ServiceBusQueueNameHelper.name
end
end
it "should be able to delete the queue" do
- response = subject.delete_queue name
+ response = subject.delete_queue queue_name
response.must_equal nil
end
end
describe "#get_queue" do
it "should be able to get a queue by name" do
- result = subject.get_queue name
+ result = subject.get_queue queue_name
result.must_be_kind_of Azure::ServiceBus::Queue
- result.name.must_equal name
+ result.name.must_equal queue_name
end
it "if the queue doesn't exists it should throw" do
assert_raises(Azure::Core::Http::HTTPError) do
subject.get_queue ServiceBusQueueNameHelper.name
@@ -132,11 +132,11 @@
result.must_be :kind_of?, Array
q_found = false
q1_found = false
q2_found = false
result.each { |q|
- q_found = true if q.name == name
+ q_found = true if q.name == queue_name
q1_found = true if q.name == name1
q2_found = true if q.name == name2
}
assert (q_found and q1_found and q2_found), "list_queues did not return expected queues"
end
@@ -166,11 +166,11 @@
it "should be able to send a message to a queue" do
msg = Azure::ServiceBus::BrokeredMessage.new("some text") do |m|
m.to = "yo"
end
- res = subject.send_queue_message name, msg
+ res = subject.send_queue_message queue_name, msg
res.must_be_nil
end
describe "when the queue has messages" do
let(:messageContent) { 'messagecontent' }
@@ -188,14 +188,14 @@
"CustomNilProperty" => nil,
"CustomJSONProperty" => "testingpa\n\"{}\\rtition"
}}
let(:msg) { m = Azure::ServiceBus::BrokeredMessage.new(messageContent, properties); m.to = 'me'; m }
- before { subject.send_queue_message name, msg }
+ before { subject.send_queue_message queue_name, msg }
it "should be able to peek a message from a queue" do
- retrieved = subject.peek_lock_queue_message name
+ retrieved = subject.peek_lock_queue_message queue_name
retrieved.must_be :kind_of?, Azure::ServiceBus::BrokeredMessage
retrieved.body.must_equal msg.body
retrieved.to.must_equal msg.to
retrieved.label.must_equal msg.label
@@ -212,51 +212,51 @@
refute retrieved.lock_token.nil?
refute retrieved.sequence_number.nil?
end
it "should be able to read-delete a message from a queue" do
- retrieved = subject.read_delete_queue_message name
+ retrieved = subject.read_delete_queue_message queue_name
retrieved.must_be :kind_of?, Azure::ServiceBus::BrokeredMessage
retrieved.body.must_equal msg.body
retrieved.to.must_equal msg.to
# it should be deleted
- retrieved = subject.read_delete_queue_message name, { :timeout => 2 }
+ retrieved = subject.read_delete_queue_message queue_name, { :timeout => 2 }
retrieved.must_be_nil
end
it "should be able to unlock a message from a queue" do
- retrieved = subject.peek_lock_queue_message name, { :timeout => 2 }
+ retrieved = subject.peek_lock_queue_message queue_name, { :timeout => 2 }
# There shouldn't be an available message in the queue
- retrieved2 = subject.peek_lock_queue_message name, { :timeout => 2 }
+ retrieved2 = subject.peek_lock_queue_message queue_name, { :timeout => 2 }
retrieved2.must_be_nil
# Unlock the message
res = subject.unlock_queue_message retrieved
res.must_be_nil
# The message should be available once again
- retrieved = subject.peek_lock_queue_message name, { :timeout => 2 }
+ retrieved = subject.peek_lock_queue_message queue_name, { :timeout => 2 }
retrieved.body.must_equal msg.body
end
it "should be able to delete a message from a queue" do
- retrieved = subject.peek_lock_queue_message name
+ retrieved = subject.peek_lock_queue_message queue_name
retrieved.body.must_equal msg.body
subject.delete_queue_message retrieved
# it should be deleted
- retrieved = subject.peek_lock_queue_message name, { :timeout => 2 }
+ retrieved = subject.peek_lock_queue_message queue_name, { :timeout => 2 }
assert_nil retrieved
end
it "should be able to read a message from a queue" do
- subject.send_queue_message name, msg
- retrieved = subject.receive_queue_message name
+ subject.send_queue_message queue_name, msg
+ retrieved = subject.receive_queue_message queue_name
retrieved.must_be :kind_of?, Azure::ServiceBus::BrokeredMessage
retrieved.body.must_equal msg.body
retrieved.to.must_equal msg.to
end
\ No newline at end of file