Back to Repositories

Testing RocketMQ Consumer Properties Runtime Hints in Spring Cloud Alibaba

This test suite validates the runtime hints registration for RocketMQ Consumer Properties in Spring Cloud Alibaba’s RocketMQ Stream Binder. It ensures proper reflection access for critical consumer configuration methods and constructors during AOT compilation.

Test Coverage Overview

The test coverage focuses on validating runtime hints registration for RocketMQ consumer properties.

Key areas tested include:

Constructor accessibility for RocketMQConsumerProperties
Method reflection access for message model configuration
Push configuration getter accessibility
Subscription setting method availability

Implementation Analysis

The testing approach utilizes Spring’s RuntimeHints framework to verify AOT compilation support. The implementation leverages JUnit 5 with AssertJ assertions to validate runtime hint registration for specific reflection targets.

The test employs Spring’s RuntimeHintsPredicates to verify proper registration of constructors and methods essential for RocketMQ consumer configuration.

Technical Details

Testing tools and components:

JUnit Jupiter for test execution
Spring AOT RuntimeHints for compilation hints
ReflectionUtils for method discovery
AssertJ for assertions
RuntimeHintsPredicates for validation

Best Practices Demonstrated

The test suite exemplifies several testing best practices:

Focused test scope with clear validation targets
Proper exception handling for reflection operations
Use of modern assertion libraries
Clean separation of setup and verification
Comprehensive coverage of reflection-based operations

alibaba/spring-cloud-alibaba

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/test/java/com/alibaba/cloud/stream/binder/rocketmq/aot/hint/RocketMQConsumerPropertiesHintsTests.java

            
/*
 * Copyright 2013-2023 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.alibaba.cloud.stream.binder.rocketmq.aot.hint;

import java.lang.reflect.Constructor;
import java.lang.reflect.Method;

import com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties;
import org.junit.jupiter.api.Test;

import org.springframework.aot.hint.RuntimeHints;
import org.springframework.aot.hint.predicate.RuntimeHintsPredicates;
import org.springframework.util.ReflectionUtils;

import static org.assertj.core.api.Assertions.assertThat;

/**
 * @author ChengPu raozihao
 */
public class RocketMQConsumerPropertiesHintsTests {

	@Test
	public void shouldRegisterHints() {
		Constructor<RocketMQConsumerProperties> constructor;
		try {
			constructor = RocketMQConsumerProperties.class.getConstructor();
		}
		catch (NoSuchMethodException e) {
			throw new RuntimeException(e);
		}
		Method setMessageModel = ReflectionUtils.findMethod(RocketMQConsumerProperties.class, "setMessageModel", String.class);
		Method getPush = ReflectionUtils.findMethod(RocketMQConsumerProperties.class, "getPush");
		Method setSubscription = ReflectionUtils.findMethod(RocketMQConsumerProperties.class, "setSubscription", String.class);
		RuntimeHints hints = new RuntimeHints();
		new RocketMQConsumerPropertiesHints().registerHints(hints, getClass().getClassLoader());
		assertThat(RuntimeHintsPredicates.reflection().onConstructor(constructor)).accepts(hints);
		assertThat(RuntimeHintsPredicates.reflection().onMethod(setMessageModel)).accepts(hints);
		assertThat(RuntimeHintsPredicates.reflection().onMethod(getPush)).accepts(hints);
		assertThat(RuntimeHintsPredicates.reflection().onMethod(setSubscription)).accepts(hints);
	}
}