def METHOD_NAME(self):
    # setup_system()
    self.redis = (
        fakeredis.FakeStrictRedis()
    )  # (server=fakeredis.FakeServer(), version=7)
    orig_xadd = self.redis.xadd
    self.xadd_id = ""
    def xadd_side_effect(*args, **kwargs):
        self.xadd_id = orig_xadd(*args, **kwargs)
        return self.xadd_id
    def xread_side_effect(*args, **kwargs):
        return [
            ["topic", [[self.xadd_id, {"id": self.xadd_id, "result": "SUCCESS"}]]]
        ]
    self.redis.xadd = Mock()
    self.redis.xadd.side_effect = xadd_side_effect
    self.redis.xread = Mock()
    self.redis.xread.side_effect = xread_side_effect
    self.patcher = patch("redis.Redis", return_value=self.redis)
    self.mock_redis = self.patcher.start()
    self.addCleanup(self.patcher.stop)
    self.model = TargetModel(name="INST", scope="DEFAULT")
    self.model.create()
    collect = Packet("INST", "COLLECT")
    Store.hset("DEFAULT__openc3cmd__INST", "COLLECT", json.dumps(collect.as_json()))
    abort = Packet("INST", "ABORT")
    Store.hset("DEFAULT__openc3cmd__INST", "ABORT", json.dumps(abort.as_json()))