@abc.abstractmethod
    def migrate(self, *args, **kwargs):
        pass
Test if we get message back on all topics if we send a message to /topic/*/
dataset/ETHPy150Open MirantisWorkloadMobility/CloudFerry/cloudferry/lib/os/migrate/base.py/ObjectTask.migrate--crossover with--dataset/ETHPy150Open ebu/radiodns-plugit/RadioVisServer/tests.py/MainTests.test_subscrible_message_on_all