Implement #getComponentType by default

Signed-off-by: Tran Ngoc Nhan <[email protected]>

Author: ngocnhan-tran1996

spring-integration-core/src/main/java/org/springframework/integration/channel/DefaultHeaderChannelRegistry.java

@@ -259,6 +259,11 @@ public void run() {
 		}
 	}
 
+	@Override
+	public String getComponentType() {
+		return "channel";
+	}
+
 	protected record MessageChannelWrapper(MessageChannel channel, long expireAt) {
 
 	}

spring-integration-core/src/main/java/org/springframework/integration/codec/CodecMessageConverter.java

@@ -77,4 +77,9 @@ public Message<?> toMessage(Object payload, @Nullable MessageHeaders headers) {
 		}
 	}
 
+	@Override
+	public String getComponentType() {
+		return "converter";
+	}
+
 }

spring-integration-core/src/main/java/org/springframework/integration/context/IntegrationObjectSupport.java

@@ -138,14 +138,6 @@ public void setComponentName(String componentName) {
 		this.componentName = componentName;
 	}
 
-	/**
-	 * Subclasses may implement this method to provide component type information.
-	 */
-	@Override
-	public String getComponentType() {
-		return "integration-object-support";
-	}
-
 	@Override
 	public void setComponentSource(Object source) {
 		this.beanSource = source;

spring-integration-core/src/main/java/org/springframework/integration/dsl/RouterSpec.java

@@ -278,6 +278,11 @@ else if (conversionService.canConvert(key.getClass(), String.class)) {
 			}
 		}
 
+		@Override
+		public String getComponentType() {
+			return "router-mapping-provider";
+		}
+
 	}
 
 }

spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java

@@ -201,6 +201,11 @@ public final void stop(Runnable callback) {
 		}
 	}
 
+	@Override
+	public String getComponentType() {
+		return "endpoint";
+	}
+
 	/**
 	 * Stop the component and invoke callback.
 	 * @param callback the Runnable to invoke.

spring-integration-core/src/main/java/org/springframework/integration/handler/advice/AbstractRequestHandlerAdvice.java

@@ -73,6 +73,11 @@ public final Object invoke(final MethodInvocation invocation) throws Throwable {
 		}
 	}
 
+	@Override
+	public String getComponentType() {
+		return "advice";
+	}
+
 	/**
 	 * Subclasses implement this method to apply behavior to the {@link MessageHandler}.
 	 * <p>

spring-integration-core/src/main/java/org/springframework/integration/transaction/ExpressionEvaluatingTransactionSynchronizationProcessor.java

@@ -131,6 +131,11 @@ public void processAfterRollback(IntegrationResourceHolder holder) {
 		doProcess(holder, this.afterRollbackExpression, this.afterRollbackChannel, "afterRollback");
 	}
 
+	@Override
+	public String getComponentType() {
+		return "processor";
+	}
+
 	private void doProcess(IntegrationResourceHolder holder, Expression expression,
 			@Nullable MessageChannel messageChannel, String expressionType) {
 

spring-integration-core/src/main/java/org/springframework/integration/transformer/AbstractTransformer.java

@@ -45,6 +45,11 @@ public final Message<?> transform(Message<?> message) {
 		}
 	}
 
+	@Override
+	public String getComponentType() {
+		return "transformer";
+	}
+
 	/**
 	 * Subclasses must implement this method to provide the transformation
 	 * logic. If the return value is itself a Message, it will be used as the

spring-integration-core/src/test/java/org/springframework/integration/handler/MessageHandlerChainTests.java

@@ -185,6 +185,11 @@ public void handleMessage(Message<?> message) {
 			output.send(message);
 		}
 
+		@Override
+		public String getComponentType() {
+			return "producer";
+		}
+
 	}
 
 }

spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractConnectionFactory.java

@@ -165,6 +165,11 @@ public ApplicationEventPublisher getApplicationEventPublisher() {
 		return this.applicationEventPublisher;
 	}
 
+	@Override
+	public String getComponentType() {
+		return "connection";
+	}
+
 	/**
 	 * Sets socket attributes on the socket.
 	 * @param socket The socket.