async def METHOD_NAME(
    self, message_iterator: AsyncIterator[Sequence[MessageProcessingResult]]
) -> AsyncIterator[Sequence[MessageProcessingResult]]:
    async for processing_results in message_iterator:
        for result in processing_results:
            mq_message = aio_pika.Message(body=aleph_json.dumps(result.to_dict()))
            await self.mq_message_exchange.publish(
                mq_message,
                routing_key=f"{result.status.value}.{result.item_hash}",
            )
        yield processing_results