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

# In-memory Transport - `kombu.transport.memory`

In-memory transport module for Kombu.

Simple transport using memory for storing messages. Messages can be passed only between threads.

## Features

- Type: Virtual

- Supports Direct: Yes

- Supports Topic: Yes

- Supports Fanout: No

- Supports Priority: No

- Supports TTL: Yes

## Connection String

Connection string is in the following format:

    memory://

## Transport

class kombu.transport.memory.Transport(client, **kwargs)

  In-memory Transport.

  class Channel(connection, **kwargs)

    In-memory Channel.

    after_reply_message_received(queue)

      Callback called after RPC reply received.

      Notes

      Reply queue semantics: can be used to delete the queue after transient reply message received.

    close()

      Close channel.

      Cancel all consumers, and requeue unacked messages.

    do_restore = False

      flag to restore unacked messages when channel goes out of scope.

    events = {}
    queues = {}
    supports_fanout = True

      flag set if the channel supports fanout exchanges.

  driver_name = 'memory'

    Name of driver library (e.g. ‘py-amqp’, ‘redis’).

  driver_type = 'memory'

    Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…

  driver_version()
  global_state = <kombu.transport.virtual.base.BrokerState object>

    memory backend state is global.

  implements = {'asynchronous': False, 'exchange_type': frozenset({'direct', 'fanout', 'headers', 'topic'}), 'heartbeats': False}

## Channel

class kombu.transport.memory.Channel(connection, **kwargs)

  In-memory Channel.

  after_reply_message_received(queue)

    Callback called after RPC reply received.

    Notes

    Reply queue semantics: can be used to delete the queue after transient reply message received.

  close()

    Close channel.

    Cancel all consumers, and requeue unacked messages.

  do_restore = False

    flag to restore unacked messages when channel goes out of scope.

  events = {}
  queues = {}
  supports_fanout = True

    flag set if the channel supports fanout exchanges.