missive.adapters package¶
Submodules¶
missive.adapters.redis module¶
missive.adapters.stdin module¶
-
class
missive.adapters.stdin.StdinAdapter(message_cls: Type[M], processor: missive.missive.Processor[~M][M], filelike: Optional[BinaryIO] = None)¶ Bases:
missive.missive.Adapter-
ack(message: M) → None¶ Mark a message as acknowledged.
Parameters: message – The message object to be acknowledged.
-
nack(message: M) → None¶ Mark a message as negatively acknowledged.
The meaning of this can vary depending on the message transport in question but generally it either returns the message to the message bus queue from which it came or triggers some special processing via some (message bus specific) dead letter queue.
Parameters: message – The message object to be acknowledged.
-
run() → None¶
-