Get a single list of messages from all storage backends.
(self, *args, **kwargs)
| 19 | self._used_storages = set() |
| 20 | |
| 21 | def _get(self, *args, **kwargs): |
| 22 | """ |
| 23 | Get a single list of messages from all storage backends. |
| 24 | """ |
| 25 | all_messages = [] |
| 26 | for storage in self.storages: |
| 27 | messages, all_retrieved = storage._get() |
| 28 | # If the backend hasn't been used, no more retrieval is necessary. |
| 29 | if messages is None: |
| 30 | break |
| 31 | if messages: |
| 32 | self._used_storages.add(storage) |
| 33 | all_messages.extend(messages) |
| 34 | # If this storage class contained all the messages, no further |
| 35 | # retrieval is necessary |
| 36 | if all_retrieved: |
| 37 | break |
| 38 | return all_messages, all_retrieved |
| 39 | |
| 40 | def _store(self, messages, response, *args, **kwargs): |
| 41 | """ |