Configuration Module

class amqp.config.amq_configuration.AMQAdapter(config)

Bases: object

configuration with prefix ‘cm.amq-adapter’

Parameters:

config (ConfigParser)

PREFIX: str = 'cm.amq-adapter.'

__init__(config)

cm.amq-adapter.service-name=amq-adapter cm.amq-adapter.generator-id=164 cm.amq-adapter.route-mapping=

Parameters:

config (ConfigParser) – config parser to read configuration values

adapter_prefix()

Return type:

str

class amqp.config.amq_configuration.Dispatch(config)

Bases: object

configuration with prefix ‘cm.dispatch’

Parameters:

config (ConfigParser)

PREFIX: str = 'cm.dispatch.'

__init__(config)

cm.dispatch.use-dlq=true cm.dispatch.amq-host=rabbitmq cm.dispatch.amq-port=5672 cm.dispatch.amq-port-tls=5671 cm.dispatch.service-host= cm.dispatch.service-port=8080

Parameters:

config (ConfigParser) – config parser to read configuration values

class amqp.config.amq_configuration.Backpressure(config)

Bases: object

configuration with prefix ‘cm.backpressure’

Parameters:

config (ConfigParser)

PREFIX: str = 'cm.backpressure.'

__init__(config)

cm.backpressure.threshold=20 cm.backpressure.time-window=3000

Parameters:

config (ConfigParser) – config parser to read configuration values

class amqp.config.amq_configuration.AMQConfiguration(config_file_name=None)

Bases: object

Top level configuration context holder / object

Parameters:

config_file_name (str)

__init__(config_file_name=None)

Parameters:

config_file_name (str)

get_unique_instance_id()

Get a unique instance ID for this AMQ service.

Returns:

A unique instance ID

Return type:

int