@Override
    public ExecuteContext after(ExecuteContext context) {
        DefaultLitePullConsumer pullConsumer = (DefaultLitePullConsumer) context.getObject();
        RocketMqPullConsumerController.cachePullConsumer(pullConsumer);

        // Get cached consumer packaging class instances
        DefaultLitePullConsumerWrapper pullConsumerWrapper =
                RocketMqPullConsumerController.getPullConsumerWrapper(pullConsumer);
        updatePushConsumerWrapperInfo(pullConsumerWrapper);

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

        // Consumer activation will execute consumption prohibition on consumers based on the cached consumption
        // prohibition configuration
        disablePullConsumption(pullConsumerWrapper);
        return context;
    }
@Test
    public void testAfter() {
        // the subscription method is assign
        PullConsumerLocalInfoUtils.setSubscriptionType(SubscriptionType.ASSIGN);
        PullConsumerLocalInfoUtils.setMessageQueue(messageQueues);
        interceptor.after(context);
        Assert.assertEquals(pullConsumerWrapper.getSubscriptionType().name(), "ASSIGN");
        Assert.assertEquals(pullConsumerWrapper.getMessageQueues(), messageQueues);
        PullConsumerLocalInfoUtils.removeMessageQueue();
        PullConsumerLocalInfoUtils.removeSubscriptionType();

        // subscription method is SUBSCRIBE
        PullConsumerLocalInfoUtils.setSubscriptionType(SubscriptionType.SUBSCRIBE);
        interceptor.after(context);
        Assert.assertTrue(pullConsumerWrapper.getSubscribedTopics().contains("test-topic"));
        Assert.assertEquals(pullConsumerWrapper.getSubscriptionType().name(), "SUBSCRIBE");
        PullConsumerLocalInfoUtils.removeSubscriptionType();
    }