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