Write some tests for #2391

spring-cloud-alibaba-examples/rocketmq-example/rocketmq-comprehensive-example/src/main/resources/application.yml

@@ -25,6 +25,7 @@ spring:
           destination: square
         processor-in-0:
           destination: num
+          group: processor_group
         consumer-in-0:
           destination: square
 

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/constant/RocketMQConst.java

@@ -31,7 +31,7 @@ public class RocketMQConst extends MessageConst {
 	/**
 	 * Default group for SCS RocketMQ Binder.
 	 */
-	public static final String DEFAULT_GROUP = "binder_default_group_name";
+	public static final String DEFAULT_GROUP = "anonymous";
 
 	/**
 	 * user args for SCS RocketMQ Binder.

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/test/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinderTest.java

@@ -0,0 +1,90 @@
+/*
+ * Copyright 2013-2022 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;
+
+import javax.annotation.Resource;
+
+import com.alibaba.cloud.stream.binder.rocketmq.autoconfigurate.ExtendedBindingHandlerMappingsProviderConfiguration;
+import com.alibaba.cloud.stream.binder.rocketmq.autoconfigurate.RocketMQBinderAutoConfiguration;
+import com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.cloud.stream.binder.ExtendedConsumerProperties;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.integration.core.MessageProducer;
+
+import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.NONE;
+
+
+@SpringBootTest(classes = RocketMQMessageChannelBinderTest.TestConfig.class,
+	webEnvironment = NONE,
+	properties = {
+			"spring.cloud.stream.rocketmq.binder.name-server=127.0.0.1:9876",
+			"spring.cloud.stream.bindings.output.destination=TopicOrderTest",
+			"spring.cloud.stream.bindings.output.content-type=application/json",
+
+			"spring.cloud.stream.bindings.input1.destination=TopicOrderTest",
+			"spring.cloud.stream.bindings.input1.content-type=application/json",
+			"spring.cloud.stream.bindings.input1.group=test-group1",
+			"spring.cloud.stream.rocketmq.bindings.input1.consumer.push.orderly=true",
+			"spring.cloud.stream.bindings.input1.consumer.maxAttempts=1",
+			"spring.cloud.stream.bindings.input2.destination=TopicOrderTest",
+			"spring.cloud.stream.bindings.input2.content-type=application/json",
+			"spring.cloud.stream.bindings.input2.group=test-group2",
+			"spring.cloud.stream.rocketmq.bindings.input2.consumer.push.orderly=false",
+			"spring.cloud.stream.rocketmq.bindings.input2.consumer.subscription=tag1"
+	})
+public class RocketMQMessageChannelBinderTest {
+	@Resource
+	RocketMQMessageChannelBinder binder;
+	@Test
+	public void createConsumerEndpoint() throws Exception {
+		TestConsumerDestination destination = new TestConsumerDestination("test");
+		MessageProducer consumerEndpoint = binder.createConsumerEndpoint(destination, "test",
+				new ExtendedConsumerProperties<>(new RocketMQConsumerProperties()));
+		Assertions.assertNotNull(consumerEndpoint);
+	}
+
+	@Test
+	public void createAnymousConsumerEndpoint() throws Exception {
+		TestConsumerDestination destination = new TestConsumerDestination("test");
+		MessageProducer consumerEndpoint = binder.createConsumerEndpoint(destination, null,
+				new ExtendedConsumerProperties<>(new RocketMQConsumerProperties()));
+		Assertions.assertNotNull(consumerEndpoint);
+	}
+
+	@Test
+	public void createDLQAnymousConsumerEndpoint() throws Exception {
+		TestConsumerDestination destination = new TestConsumerDestination("%DLQ%test");
+		Assertions.assertThrows(RuntimeException.class, () -> {
+			MessageProducer consumerEndpoint = binder.createConsumerEndpoint(destination, null,
+					new ExtendedConsumerProperties<>(new RocketMQConsumerProperties()));
+		});
+	}
+
+	@Configuration
+	@EnableAutoConfiguration
+	@ImportAutoConfiguration({ ExtendedBindingHandlerMappingsProviderConfiguration.class,
+			RocketMQBinderAutoConfiguration.class})
+	public static class TestConfig {
+
+	}
+}

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/test/java/com/alibaba/cloud/stream/binder/rocketmq/TestConsumerDestination.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright 2013-2022 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;
+
+import org.springframework.cloud.stream.provisioning.ConsumerDestination;
+
+public class TestConsumerDestination implements ConsumerDestination {
+	private String name;
+
+	public TestConsumerDestination(String name) {
+		this.name = name;
+	}
+
+	@Override
+	public String getName() {
+		return name;
+	}
+}