@Override
    public ExecuteContext after(ExecuteContext context) {
        DefaultMQPushConsumer pushConsumer = (DefaultMQPushConsumer) context.getObject();
        RocketMqPushConsumerController.cachePushConsumer(pushConsumer);

        DefaultMqPushConsumerWrapper pushConsumerWrapper =
                RocketMqPushConsumerController.getPushConsumerWrapper(pushConsumer);
        if (pushConsumerWrapper != null) {
            pushConsumerWrapper.setSubscribedTopics(pushConsumerWrapper.getPushConsumerImpl()
                    .getSubscriptionInner().keySet());
        }

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

        // Consumer activation will execute Prohibition of consumption on consumers based on the cached prohibition of
        // consumption configuration
        disablePushConsumption(pushConsumerWrapper);
        return context;
    }
@Test
    public void testAfter() {
        interceptor.after(context);
        Assert.assertTrue(pushConsumerWrapper.getSubscribedTopics().contains("test-topic"));
    }