@Override
    public ExecuteContext after(ExecuteContext context) {
        if (handler != null) {
            handler.doAfter(context);
            return context;
        }

        DefaultMqPushConsumerWrapper wrapper =
                RocketMqPushConsumerController.getPushConsumerWrapper((DefaultMQPushConsumer)context.getObject());

        disablePushConsumption(wrapper);
        return context;
    }
@Test
    public void testAfter() throws MQClientException {
        pushConsumer.subscribe("test-topic", "*");
        interceptor.after(context);
        Assert.assertTrue(pushConsumerWrapper.getSubscribedTopics().contains("test-topic"));
    }