java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalConsumer.java [42:50]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.listener = listener;
        try {
            consumer.subscribe(topic, tag);
            consumer.setMessageListener(listener);
            consumer.start();
        } catch (MQClientException e) {
            logger.info("Start DefaultMQPushConsumer failed, {}", e.getMessage());
        }
        logger.info("DefaultMQPushConsumer started - topic: {}, tag: {}", topic, tag);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalConsumer.java [54:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.listener = listener;
        try {
            consumer.subscribe(topic, tag);
            consumer.setMessageListener(listener);
            consumer.start();
        } catch (MQClientException e) {
            logger.info("Start DefaultMQPushConsumer failed, {}", e.getMessage());
        }
        logger.info("DefaultMQPushConsumer started - topic: {}, tag: {}", topic, tag);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -