spec/message_queue_spec.rb in zk-0.9.1 vs spec/message_queue_spec.rb in zk-1.0.0.rc.1
- old
+ new
@@ -1,11 +1,11 @@
require File.join(File.dirname(__FILE__), %w[spec_helper])
describe ZK::MessageQueue do
before(:each) do
- @zk = ZK.new("localhost:#{ZK_TEST_PORT}", :watcher => :default)
- @zk2 = ZK.new("localhost:#{ZK_TEST_PORT}", :watcher => :default)
+ @zk = ZK.new("localhost:#{ZK_TEST_PORT}")
+ @zk2 = ZK.new("localhost:#{ZK_TEST_PORT}")
wait_until{ @zk.connected? && @zk2.connected? }
@queue_name = "_specQueue"
@consume_queue = @zk.queue(@queue_name)
@publish_queue = @zk2.queue(@queue_name)
end