Back to Repositories

Validating RocketMQ Properties Runtime Hints in Spring Cloud Alibaba

This test suite validates the runtime hints registration for RocketMQ properties provider in Spring Cloud Alibaba’s stream binder implementation. It ensures proper reflection configuration for RocketMQ consumer and producer properties handling during AOT processing.

Test Coverage Overview

The test suite provides comprehensive coverage of runtime hints registration for RocketMQ specific properties.

Key areas tested include:

Constructor reflection access for RocketMQSpecificPropertiesProvider
Getter and setter method reflection for consumer properties
Getter and setter method reflection for producer properties
Integration with Spring AOT processing system

Implementation Analysis

The testing approach utilizes Spring’s RuntimeHints infrastructure to verify AOT compilation support.

Implementation features:

Uses Spring’s RuntimeHintsPredicates for assertion validation
Leverages reflection utilities to access methods and constructors
Implements systematic verification of all required reflection hints

Technical Details

Testing tools and configuration:

JUnit Jupiter for test execution
AssertJ for assertions
Spring AOT RuntimeHints framework
ReflectionUtils for method access
Custom RocketMQSpecificPropertiesProviderHints implementation

Best Practices Demonstrated

The test suite exemplifies several testing best practices in Spring Cloud development.

Notable practices include:

Systematic verification of AOT compilation requirements
Proper exception handling for reflection operations
Clear separation of test setup and assertions
Comprehensive validation of all reflection access points

alibaba/spring-cloud-alibaba

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/test/java/com/alibaba/cloud/stream/binder/rocketmq/aot/hint/RocketMQSpecificPropertiesProviderHintsTests.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 com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties;
import com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQSpecificPropertiesProvider;
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 RocketMQSpecificPropertiesProviderHintsTests {

	@Test
	public void shouldRegisterHints() {
		Constructor<RocketMQSpecificPropertiesProvider> constructor;
		try {
			constructor = RocketMQSpecificPropertiesProvider.class.getConstructor();
		}
		catch (NoSuchMethodException e) {
			throw new RuntimeException(e);
		}
		Method getConsumer = ReflectionUtils.findMethod(RocketMQSpecificPropertiesProvider.class, "getConsumer");
		Method setConsumer = ReflectionUtils.findMethod(RocketMQSpecificPropertiesProvider.class, "setConsumer", RocketMQConsumerProperties.class);
		Method getProducer = ReflectionUtils.findMethod(RocketMQSpecificPropertiesProvider.class, "getProducer");
		Method setProducer = ReflectionUtils.findMethod(RocketMQSpecificPropertiesProvider.class, "setProducer", RocketMQProducerProperties.class);
		RuntimeHints hints = new RuntimeHints();
		new RocketMQSpecificPropertiesProviderHints().registerHints(hints, getClass().getClassLoader());
		assertThat(RuntimeHintsPredicates.reflection().onConstructor(constructor)).accepts(hints);
		assertThat(RuntimeHintsPredicates.reflection().onMethod(getConsumer)).accepts(hints);
		assertThat(RuntimeHintsPredicates.reflection().onMethod(setConsumer)).accepts(hints);
		assertThat(RuntimeHintsPredicates.reflection().onMethod(getProducer)).accepts(hints);
		assertThat(RuntimeHintsPredicates.reflection().onMethod(setProducer)).accepts(hints);
	}
}