Types

class yapw.types.State(format_routing_key, interrupt, connection, exchange, encode, content_type, delivery_mode)

Attributes that can be used safely in consumer callbacks.

Parameters:

• format_routing_key (Callable[[str], str])

• interrupt (Callable[[T], None])

• connection (T)

• exchange (str)

• encode (Callable[[Any, str], bytes])

• content_type (str)

• delivery_mode (int)

format_routing_key: Callable[[str], str]

A function to format the routing key.

interrupt: Callable[[T], None]

A function to shut down the client.

connection: T

The connection.

exchange: str

The exchange name.

encode: Callable[[Any, str], bytes]

The message bodies’ encoder.

content_type: str

The messages’ content type.

delivery_mode: int

The messages’ delivery mode.

class yapw.types.PublishKeywords

Keyword arguments for basic_publish.

exchange: str

The exchange to publish to.

routing_key: str

The message’s routing key.

body: bytes

The message’s body.

properties: BasicProperties

The message’s content type and delivery mode.