class documentation

class MessageProducer:

Constructor: MessageProducer(msg, buffer, scheduler)

View In Hierarchy

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):

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):

Undocumented

CHUNK_SIZE =

Undocumented

Value
2 ** (2 ** (2 ** 2))
buffer =

Undocumented

consumer =

Undocumented

msg =

Undocumented

scheduler =

Undocumented

write =

Undocumented

def _produce(self):

Undocumented

_uuid4 =

Undocumented