class MessageProducer: (source)
Undocumented
Class Variable | CHUNK_SIZE |
Undocumented |
Method | __init__ |
Produce this message. |
Instance Variable | msg |
Undocumented |
Instance Variable | buffer |
Undocumented |
Instance Variable | scheduler |
Undocumented |
Instance Variable | write |
Undocumented |
Method | beginProducing |
Undocumented |
Instance Variable | consumer |
Undocumented |
Class Variable | _uuid4 |
Undocumented |
Method | _produce |
Undocumented |
Produce this message.
Parameters | msg | The message I am to produce. (type: IMessage ) |
buffer | A buffer to hold the message in. If None, I will use a tempfile.TemporaryFile . (type: file-like) | |
scheduler | Undocumented |