У меня есть метод, который непрерывно опрашивает очередь на наличие сообщений. Я хотел бы проверить, что сообщение передается в правильный класс. Как мне это сделать. Скажем, у меня есть этот код:
def receive_messages(queue):
"""
Loops forever, polling the queue for messages.
"""
while True:
messages_to_delete = []
for message in queue.receive_messages():
try:
ProcessorFactory(message)().process
Я бы хотел пройти эту фиктивную очередь и проверить, что макет ProcessorFactory
получает правильные сообщения. Как бы я сделал это без замыкания в бесконечном цикле?