@Override
    public ExecuteContext after(ExecuteContext context) {
        DefaultLitePullConsumerWrapper wrapper = RocketMqPullConsumerController
                .getPullConsumerWrapper((DefaultLitePullConsumer) context.getObject());
        if (wrapper == null) {
            PullConsumerLocalInfoUtils.setSubscriptionType(SubscriptionType.SUBSCRIBE);
        } else {
            wrapper.setSubscriptionType(SubscriptionType.SUBSCRIBE);
        }

        if (handler != null) {
            handler.doAfter(context);
            return context;
        }

        // After adding topic subscriptions, consumer subscription information changes, and consumers need to be enabled
        // or prohibited from consuming according to the prohibited topic configuration
        disablePullConsumption(wrapper);
        return context;
    }
@Test
    public void testAfter() {
        // Wrapper is null
        interceptor.after(context);
        Assert.assertEquals(PullConsumerLocalInfoUtils.getSubscriptionType().name(), "SUBSCRIBE");
        PullConsumerLocalInfoUtils.removeSubscriptionType();

        // Wrapper is not null
        pullConsumerWrapper.setSubscribedTopics(subscription.keySet());
        subscription.put("test-topic", new SubscriptionData());
        RocketMqPullConsumerController.cachePullConsumer(pullConsumer);
        interceptor.after(context);
        Assert.assertEquals(pullConsumerWrapper.getSubscriptionType().name(), "SUBSCRIBE");
        Assert.assertEquals(pullConsumerWrapper.getSubscribedTopics(), subscription.keySet());
    }