message_spec.rb in cloudist-0.4.4

- old
+ new
@@ -1,91 +1,91 @@
 require File.expand_path('../../spec_helper', __FILE__)
 
-describe Cloudist::Message do
-  before(:each) do
-    stub_amqp!  
-    @queue = Cloudist::Queue.new("test.queue")
-    @queue.stubs(:publish)
-    @headers = {}
-  end
-  
-  it "should have a unique id when new" do
-    msg = Cloudist::Message.new({:hello => "world"}, @headers)
-    msg.id.size.should == "57b474f0-496c-012e-6f57-34159e11a916".size
-  end
-  
-  it "should not update id when existing message" do
-    msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
-    msg.update_headers
-    msg.id.should == "not-an-id"
-  end
-  
-  it "should remove id from headers and update with message_id" do
-    msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
-    msg.update_headers
-    msg.id.should == "not-an-id"
-    msg.headers.id.should == nil
-    
-    msg = Cloudist::Message.new({:hello => "world"}, {:message_id => "not-an-id"})
-    msg.update_headers
-    msg.id.should == "not-an-id"
-    msg.headers.id.should == nil
-  end
-  
-  it "should update headers" do
-    msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
-    msg.update_headers
-    
-    msg.headers.keys.should include *["ttl", "timestamp", "message_id"]
-  end
-  
-  it "should allow custom header when updating" do
-    msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
-    msg.update_headers(:message_type => "reply")
-    
-    msg.headers.keys.should include *["ttl", "timestamp", "message_id", "message_type"]
-  end
-  
-  it "should not be published if timestamp is not in headers" do
-    msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
-    msg.published?.should be_false
-  end
-  
-  it "should be published if timestamp is in headers" do
-    msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
-    msg.publish(@queue)
-    msg.published?.should be_true
-  end
-  
-  it "should include ttl in headers" do
-    msg = Cloudist::Message.new({:hello => "world"})
-    # msg.publish(@queue)
-    msg.headers[:ttl].should == "300"
-  end
-  
-  it "should get created_at date from header" do
-    time = Time.now.to_f
-    msg = Cloudist::Message.new({:hello => "world"}, {:timestamp => time})
-    msg.created_at.to_f.should == time
-  end
-  
-  it "should set published_at when publishing" do
-    time = Time.now.to_f
-    msg = Cloudist::Message.new({:hello => "world"}, {:timestamp => time})
-    msg.publish(@queue)
-    msg.published_at.to_f.should > time
-  end
-  
-  it "should have latency" do
-    time = (Time.now).to_f
-    msg = Cloudist::Message.new({:hello => "world"}, {:timestamp => time})
-    sleep(0.1)
-    msg.publish(@queue)
-    msg.latency.should be_within(0.001).of(0.1)
-  end
-  
-  it "should reply to sender" do
-    msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
-    msg.reply(:success => true)
-  end
-  
-end
+# describe Cloudist::Message do
+#   before(:each) do
+#     stub_amqp!
+#     @queue = Cloudist::Queue.new("test.queue")
+#     @queue.stubs(:publish)
+#     @headers = {}
+#   end
+#
+#   it "should have a unique id when new" do
+#     msg = Cloudist::Message.new({:hello => "world"}, @headers)
+#     msg.id.size.should == "57b474f0-496c-012e-6f57-34159e11a916".size
+#   end
+#
+#   it "should not update id when existing message" do
+#     msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
+#     msg.update_headers
+#     msg.id.should == "not-an-id"
+#   end
+#
+#   it "should remove id from headers and update with message_id" do
+#     msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
+#     msg.update_headers
+#     msg.id.should == "not-an-id"
+#     msg.headers.id.should == nil
+#
+#     msg = Cloudist::Message.new({:hello => "world"}, {:message_id => "not-an-id"})
+#     msg.update_headers
+#     msg.id.should == "not-an-id"
+#     msg.headers.id.should == nil
+#   end
+#
+#   it "should update headers" do
+#     msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
+#     msg.update_headers
+#
+#     msg.headers.keys.should include *["ttl", "timestamp", "message_id"]
+#   end
+#
+#   it "should allow custom header when updating" do
+#     msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
+#     msg.update_headers(:message_type => "reply")
+#
+#     msg.headers.keys.should include *["ttl", "timestamp", "message_id", "message_type"]
+#   end
+#
+#   it "should not be published if timestamp is not in headers" do
+#     msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
+#     msg.published?.should be_false
+#   end
+#
+#   it "should be published if timestamp is in headers" do
+#     msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
+#     msg.publish(@queue)
+#     msg.published?.should be_true
+#   end
+#
+#   it "should include ttl in headers" do
+#     msg = Cloudist::Message.new({:hello => "world"})
+#     # msg.publish(@queue)
+#     msg.headers[:ttl].should == "300"
+#   end
+#
+#   it "should get created_at date from header" do
+#     time = Time.now.to_f
+#     msg = Cloudist::Message.new({:hello => "world"}, {:timestamp => time})
+#     msg.created_at.to_f.should == time
+#   end
+#
+#   it "should set published_at when publishing" do
+#     time = Time.now.to_f
+#     msg = Cloudist::Message.new({:hello => "world"}, {:timestamp => time})
+#     msg.publish(@queue)
+#     msg.published_at.to_f.should > time
+#   end
+#
+#   it "should have latency" do
+#     time = (Time.now).to_f
+#     msg = Cloudist::Message.new({:hello => "world"}, {:timestamp => time})
+#     sleep(0.1)
+#     msg.publish(@queue)
+#     msg.latency.should be_within(0.001).of(0.1)
+#   end
+#
+#   it "should reply to sender" do
+#     msg = Cloudist::Message.new({:hello => "world"}, {:id => "not-an-id"})
+#     msg.reply(:success => true)
+#   end
+#
+# end