Updated app doc
This commit is contained in:
parent
926ed41a0f
commit
f782d167ef
8
app.py
8
app.py
@ -1,7 +1,7 @@
|
|||||||
#!/usr/bin/env python
|
#!/usr/bin/env python
|
||||||
|
|
||||||
"""
|
"""
|
||||||
Main entry point, This module builds the producer from the submodules.
|
Main entry point, this module builds the producer from the submodules.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
import os
|
import os
|
||||||
@ -34,7 +34,11 @@ if __name__ == "__main__":
|
|||||||
"""
|
"""
|
||||||
This is the producers entry point, initializes all the components (:class:`communicator.Communicator`,
|
This is the producers entry point, initializes all the components (:class:`communicator.Communicator`,
|
||||||
:class:`consumerlocator.ConsumerLocator` and :class:`messagesender.MessageSender`) and sends infinite random
|
:class:`consumerlocator.ConsumerLocator` and :class:`messagesender.MessageSender`) and sends infinite random
|
||||||
messages.
|
messages. Basically this is a big loop, learning about consumers ( :func:`consumerlocator.ConsumerLocator.learnconsumerlist` ),
|
||||||
|
updating the current ( :func:`consumerlocator.ConsumerLocator.updateconsumer` ) one and sending the message
|
||||||
|
( :func:`messagesender.MessageSender.sendmessage` ).
|
||||||
|
If the current consumer is unavailable, the update will change to an available one. To not flood the network with
|
||||||
|
infinite data, we some random time.
|
||||||
"""
|
"""
|
||||||
LOGGER.info("Producer started")
|
LOGGER.info("Producer started")
|
||||||
generateduuid = str(uuid.uuid4())
|
generateduuid = str(uuid.uuid4())
|
||||||
|
Reference in New Issue
Block a user