class Bunny

• Bunny
• Reference
• Object

Defined in:

bunny.cr

Constructors

• .new(db : DB::Database = DB.open("sqlite3://bunni.sqlite"))

Instance Method Summary

• #ack(id : UUID)
• #db : DB::Database
• #db=(db : DB::Database)
• #grab(streamName, timeout = 5000, ackTimeout = 5000)
• #grabWaiters : Hash(String, Array(Channel(Event)))
• #grabWaiters=(grabWaiters : Hash(String, Array(Channel(Event))))
• #nack(uuid : UUID, streamName : String)
• #post(streamName : String, data : Object)
• #processingEvents : Hash(UUID, Channel(UUID))
• #processingEvents=(processingEvents : Hash(UUID, Channel(UUID)))
• #show(&)

Constructor Detail

Instance Method Detail