class documentation

Undocumented

Method __init__ Produce this message.
Method beginProducing Undocumented
Constant CHUNK_SIZE Undocumented
Instance Variable buffer Undocumented
Instance Variable consumer Undocumented
Instance Variable msg Undocumented
Instance Variable scheduler Undocumented
Instance Variable write Undocumented
Method _produce Undocumented
Class Variable _uuid4 Undocumented
def __init__(self, msg, buffer=None, scheduler=None): (source)

Produce this message.

Parameters
msg:IMessageThe message I am to produce.
buffer:file-likeA buffer to hold the message in. If None, I will use a tempfile.TemporaryFile.
schedulerUndocumented
def beginProducing(self, consumer): (source)

Undocumented

CHUNK_SIZE = (source)

Undocumented

Value
2**(2**(2**2))

Undocumented

consumer = (source)

Undocumented

Undocumented

scheduler = (source)

Undocumented

Undocumented

def _produce(self): (source)

Undocumented

Undocumented