(self, connection, queues, handler)
| 115 | """ |
| 116 | |
| 117 | def __init__(self, connection, queues, handler): |
| 118 | self.connection = connection |
| 119 | |
| 120 | self._queues = queues |
| 121 | self._handler = handler |
| 122 | |
| 123 | workflows_pool_size = cfg.CONF.actionrunner.workflows_pool_size |
| 124 | actions_pool_size = cfg.CONF.actionrunner.actions_pool_size |
| 125 | self._workflows_dispatcher = BufferedDispatcher( |
| 126 | dispatch_pool_size=workflows_pool_size, name="workflows-dispatcher" |
| 127 | ) |
| 128 | self._actions_dispatcher = BufferedDispatcher( |
| 129 | dispatch_pool_size=actions_pool_size, name="actions-dispatcher" |
| 130 | ) |
| 131 | |
| 132 | def process(self, body, message): |
| 133 | try: |
nothing calls this directly
no test coverage detected