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

        DefaultLitePullConsumerWrapper wrapper = RocketMqPullConsumerController
                .getPullConsumerWrapper((DefaultLitePullConsumer) context.getObject());

        // After canceling the subscription, the consumer's subscription information will change, and they need to be
        // enabled or prohibited from consuming according to the prohibited topic configuration
        disablePullConsumption(wrapper);
        return context;
    }
@Test
    public void testAfter() {
        subscription.remove("test-topic");
        interceptor.after(context);
        Assert.assertEquals(pullConsumerWrapper.getSubscribedTopics().size(), 0);
    }