| 104 | |
| 105 | |
| 106 | class FakeVariableMessageHandler(consumers.VariableMessageHandler): |
| 107 | def __init__(self, connection, queues): |
| 108 | super(FakeVariableMessageHandler, self).__init__(connection, queues) |
| 109 | |
| 110 | self.message_types = {FakeModelDB: self.handle_fake_model} |
| 111 | |
| 112 | def process(self, message): |
| 113 | handler_function = self.message_types.get(type(message)) |
| 114 | handler_function(message) |
| 115 | |
| 116 | def handle_fake_model(self, fk_db): |
| 117 | pass |
| 118 | |
| 119 | |
| 120 | def get_variable_messages_handler(): |
no outgoing calls