public static void disablePushConsumption(DefaultMqPushConsumerWrapper wrapper, Set<String> topics) {
        Set<String> subscribedTopic = wrapper.getSubscribedTopics();
        if (subscribedTopic.stream().anyMatch(topics::contains)) {
            suspendPushConsumer(wrapper);
            return;
        }
        resumePushConsumer(wrapper);
    }
@Test
    public void testDisablePushConsumptionNoTopic() {
        pushConsumerWrapper.setProhibition(true);
        RocketMqPushConsumerController.disablePushConsumption(pushConsumerWrapper, prohibitionTopics);
        Assert.assertFalse(pushConsumerWrapper.isProhibition());
    }