republish
Republish message.
def republish(
producer: kombu.Producer,
message: kombu.Message,
exchange: string,
routing_key: string,
remove_props: list
)
Republish message.
Parameters
| Name | Type | Description |
|---|---|---|
| producer | kombu.Producer | The producer instance used to publish the message. |
| message | kombu.Message | The original message object to be republished. |
| exchange | string | The name of the exchange to publish to; defaults to the original message's exchange. |
| routing_key | string | The routing key to use; defaults to the original message's routing key. |
| remove_props | list | A list of property keys to strip from the message before republishing; defaults to application headers, content type, encoding, and headers. |
Returns
| Type | Description |
|---|---|
| Nothing is returned; the message is published to the specified exchange. |