Kombu.Simple.SimpleBuffer (Kombu v0.1.0)

Copy Markdown View Source

Simple API for ephemeral queues.

Preconfigures transient, exclusive, and auto-delete flags on the queue and exchange.

Summary

Functions

clear(buffer)

See Kombu.Simple.SimpleQueue.clear/1.

close(buffer)

See Kombu.Simple.SimpleQueue.close/1.

empty?(buffer)

See Kombu.Simple.SimpleQueue.empty?/1.

get(buffer, opts \\ [])

See Kombu.Simple.SimpleQueue.get/2.

get_nowait(buffer)

See Kombu.Simple.SimpleQueue.get_nowait/1.

new(channel, name_or_queue, opts \\ [])
put(buffer, message, opts \\ [])

See Kombu.Simple.SimpleQueue.put/3.

qsize(buffer)

See Kombu.Simple.SimpleQueue.qsize/1.

Functions

clear(buffer)

See Kombu.Simple.SimpleQueue.clear/1.

close(buffer)

See Kombu.Simple.SimpleQueue.close/1.

empty?(buffer)

See Kombu.Simple.SimpleQueue.empty?/1.

get(buffer, opts \\ [])

See Kombu.Simple.SimpleQueue.get/2.

get_nowait(buffer)

See Kombu.Simple.SimpleQueue.get_nowait/1.

new(channel, name_or_queue, opts \\ [])

@spec new(term(), String.t() | Kombu.Queue.t(), keyword()) ::
  Kombu.Simple.SimpleQueue.t()

put(buffer, message, opts \\ [])

See Kombu.Simple.SimpleQueue.put/3.

qsize(buffer)

See Kombu.Simple.SimpleQueue.qsize/1.