angee.intake.signals

Intake-owned receiver for messaging's generic message-ingested seam.

connect

def connect() -> None

Listen for ingested messages without adding another messaging hook.

capture_channel_message

def capture_channel_message(sender: Any, instance: Any, **kwargs: Any) -> None

Resolve the channel and isolate intake capture from primary message ingest.

Messaging sends this signal synchronously inside its ingest transaction, so successful capture remains atomic with the message. Capture failures must not propagate: doing so rolls back the primary message and poisons bridge retries.