This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.3.

# Simple Messaging API - `kombu.simple`

Simple messaging interface.

## Persistent

class kombu.simple.SimpleQueue(channel, name, no_ack=None, queue_opts=None, queue_args=None, exchange_opts=None, serializer=None, compression=None, accept=None)

  Simple API for persistent queues.

  channel

    Current channel

  producer

    `Producer` used to publish messages.

  consumer

    `Consumer` used to receive messages.

  no_ack

    flag to enable/disable acknowledgments.

  queue

    `Queue` to consume from (if consuming).

  queue_opts

    > Additional options for the queue declaration.

    exchange_opts

      Additional options for the exchange declaration.

  get(block=True, timeout=None)
  get_nowait()
  put(message, serializer=None, headers=None, compression=None, routing_key=None, **kwargs)
  clear()
  __len__()

    len(self) -> self.qsize().

  qsize()
  close()

## Buffer

class kombu.simple.SimpleBuffer(channel, name, no_ack=None, queue_opts=None, queue_args=None, exchange_opts=None, serializer=None, compression=None, accept=None)

  Simple API for ephemeral queues.

  channel

    Current channel

  producer

    `Producer` used to publish messages.

  consumer

    `Consumer` used to receive messages.

  no_ack

    flag to enable/disable acknowledgments.

  queue

    `Queue` to consume from (if consuming).

  queue_opts

    > Additional options for the queue declaration.

    exchange_opts

      Additional options for the exchange declaration.

  get(block=True, timeout=None)
  get_nowait()
  put(message, serializer=None, headers=None, compression=None, routing_key=None, **kwargs)
  clear()
  __len__()

    len(self) -> self.qsize().

  qsize()
  close()