moti.utils.publishers package¶
Submodules¶
moti.utils.publishers.rabbitmq_parser_publisher module¶
-
class
moti.utils.publishers.rabbitmq_parser_publisher.RabbitmqParserPublisher(queues, host, port, path, name, parsers)¶ Bases:
object-
protocol= 'rabbitmq_parser'¶
-
publish_factory(snapshot, queue)¶ This function parses the snapshot based on the parser specified by queue and sends the result to the exchange for parser publishers
Parameters: - snapshot – snapshot as read from a message queue
- queue (str) – name of queue the snapshot was rea from
-
moti.utils.publishers.rabbitmq_server_publisher module¶
-
class
moti.utils.publishers.rabbitmq_server_publisher.RabbitmqServerPublisher(queues, host, port, path, name)¶ Bases:
object-
protocol= 'rabbitmq_server'¶
-
publish(snapshot)¶ Turns the snapshot into a json :param snapshot: a Snapshot generated by the server for the protocol file
this snapshot contains an additional variable user that contains the user information from the hello message
-