Sha256: 5ced200e6b17f4d023cfe41da3ab7cc9b6b715739fc3c5c3484319e61f5ea9a4

Contents?: true

Size: 290 Bytes

Versions: 19

Compression:

Stored size: 290 Bytes

Contents

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

#Carrot.logging = true
q = Carrot.queue('carrot', :durable => true)
100.times do
  q.publish('foo', :persistent => true)
end
puts "count: #{q.message_count}"
while msg = q.pop(:ack => true)
  puts msg
  q.ack
end
Carrot.stop

Version data entries

19 entries across 19 versions & 5 rubygems

Version Path
famoseagle-carrot-0.1.0 lib/examples/simple_pop.rb
famoseagle-carrot-0.2.0 lib/examples/simple_pop.rb
famoseagle-carrot-0.3.0 lib/examples/simple_pop.rb
famoseagle-carrot-0.4.0 lib/examples/simple_pop.rb
famoseagle-carrot-0.5.0 lib/examples/simple_pop.rb
famoseagle-carrot-0.6.0 lib/examples/simple_pop.rb
famoseagle-carrot-0.7.0 lib/examples/simple_pop.rb
maxlapshin-carrot-0.6.0 lib/examples/simple_pop.rb
carrot-1.2.0 lib/examples/simple_pop.rb
carrot-1.1.0 lib/examples/simple_pop.rb
carrot-1.0.0 lib/examples/simple_pop.rb
carrot-0.8.1 lib/examples/simple_pop.rb
secure_carrot-0.2.0 lib/examples/simple_pop.rb
secure_carrot-0.1.2 lib/examples/simple_pop.rb
secure_carrot-0.1.1 lib/examples/simple_pop.rb
secure_carrot-0.1.0 lib/examples/simple_pop.rb
carrot-0.8.0 lib/examples/simple_pop.rb
sa-carrot-0.7.1 lib/examples/simple_pop.rb
carrot-0.7.0 lib/examples/simple_pop.rb