This document describes the current stable version of Kombu (5.0). For development docs, go here.

File-system Transport - kombu.transport.filesystem

File-system Transport.

Transport using the file-system as the message store.

Transport

class kombu.transport.filesystem.Transport(client, **kwargs)[source]

Filesystem Transport.

class Channel(connection, **kwargs)

Filesystem Channel.

data_folder_in
data_folder_out
processed_folder
store_processed
property transport_options
default_port = 0

port number used when no port is specified.

driver_name = 'filesystem'

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

driver_type = 'filesystem'

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

driver_version()[source]

Channel

class kombu.transport.filesystem.Channel(connection, **kwargs)[source]

Filesystem Channel.

data_folder_in[source]
data_folder_out[source]
processed_folder[source]
store_processed[source]
property transport_options