class

Kafka::Queue

Inherits Reference < Object

Constructors

new(rk : Consumer | Producer)

Create a new message queue.

Source

Instance methods

destroy

Destroys queue, purging all of the enqueued messages.

Source
to_unsafe
Source