Sha256: c7dcb1050143f39160ea0bf40f91df97ea6013db5d68455675023709b6b4887c

Contents?: true

Size: 1011 Bytes

Versions: 6

Compression:

Stored size: 1011 Bytes

Contents

require File.expand_path(File.dirname(__FILE__) + '../../spec_helper')

describe Cloudist::Request do
  before {
    @mq_header = mock("MQ::Header")
    @mq_header.stubs(:headers).returns({:published_on=>Time.now.to_i - 60, :event_hash=>"foo", :message_id=>"foo", :ttl=>300})
    
    q = Cloudist::JobQueue.new('test.queue')
    
    @request = Cloudist::Request.new(q, Marshal.dump({:bread => 'white'}), @mq_header)
  }
  
  it "should return ttl" do
    @request.ttl.should == 300
  end
  
  it "should have a payload" do
    @request.payload.should_not be_nil
    @request.payload.should be_a(Cloudist::Payload)
  end
  
  it "should be 1 minute old" do
    @request.age.should == 60
  end
  
  it "should not be expired" do
    @request.expired?.should_not be_true
  end
  
  it "should not be acked yet" do
    @request.acked?.should be_false
  end
  
  it "should be ackable" do
    @mq_header.stubs(:ack).returns(true)
    
    @request.ack.should be_true
    @request.acked?.should be_true
  end
  
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
cloudist-0.4.4 spec/cloudist/request_spec.rb
cloudist-0.4.3 spec/cloudist/request_spec.rb
cloudist-0.4.2 spec/cloudist/request_spec.rb
cloudist-0.4.1 spec/cloudist/request_spec.rb
cloudist-0.2.1 spec/cloudist/request_spec.rb
cloudist-0.2.0 spec/cloudist/request_spec.rb