#vulnerable code 
                                @Test
    public void testConsumerStartWithInterval() {
        String tag = "jueyin";
        int msgSize = 100;
        String originMsgDCName = RandomUtils.getStringByUUID();
        String msgBodyDCName = RandomUtils.getStringByUUID();

        RMQNormalConsumer consumer1 = getConsumer(nsAddr, topic, tag,
            new RMQNormalListner(originMsgDCName, msgBodyDCName));
        producer.send(tag, msgSize, 100);
        TestUtils.waitForMoment(5);
        RMQNormalConsumer consumer2 = getConsumer(nsAddr, consumer1.getConsumerGroup(), tag,
            new RMQNormalListner(originMsgDCName, msgBodyDCName));
        TestUtils.waitForMoment(5);

        consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime);
        assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(),
            consumer1.getListner().getAllMsgBody()))
            .containsExactlyElementsIn(producer.getAllMsgBody());
    } 
                            #location 16 
                            #vulnerability type NULL_DEREFERENCE
#fixed code
                                @Test
    public void testConsumerStartWithInterval() {
        int msgSize = 100;
        String originMsgDCName = RandomUtils.getStringByUUID();
        String msgBodyDCName = RandomUtils.getStringByUUID();

        RMQNormalConsumer consumer1 = getConsumer(nsAddr, topic, tag,
            new RMQNormalListner(originMsgDCName, msgBodyDCName));
        producer.send(tag, msgSize, 100);
        TestUtils.waitForMoment(5);
        getConsumer(nsAddr, consumer1.getConsumerGroup(), tag,
            new RMQNormalListner(originMsgDCName, msgBodyDCName));
        TestUtils.waitForMoment(5);

        consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime);
        assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(),
            consumer1.getListner().getAllMsgBody()))
            .containsExactlyElementsIn(producer.getAllMsgBody());
    }