Implement #getComponentType

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

Author: ngocnhan-tran1996

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

@@ -261,7 +261,7 @@ public void run() {
 
 	@Override
 	public String getComponentType() {
-		return "channel";
+		return "header-channel-registry";
 	}
 
 	protected record MessageChannelWrapper(MessageChannel channel, long expireAt) {

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

@@ -201,11 +201,6 @@ 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/endpoint/AbstractPollingEndpoint.java

@@ -183,6 +183,11 @@ public void setTransactionSynchronizationFactory(
 		this.transactionSynchronizationFactory = transactionSynchronizationFactory;
 	}
 
+	@Override
+	public String getComponentType() {
+		return "polling-endpoint";
+	}
+
 	/**
 	 * Return the default error channel if the error handler is explicitly provided and
 	 * it is a {@link MessagePublishingErrorHandler}.

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

@@ -123,4 +123,9 @@ private void logComponentSubscriptionEvent(boolean add) {
 		}
 	}
 
+	@Override
+	public String getComponentType() {
+		return "event-driven";
+	}
+
 }

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

@@ -111,6 +111,11 @@ public void setOutputChannelName(String outputChannelName) {
 		return this.outputChannel;
 	}
 
+	@Override
+	public String getComponentType() {
+		return "message-producer";
+	}
+
 	public void setErrorChannel(MessageChannel errorChannel) {
 		this.errorChannel = errorChannel;
 	}

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

@@ -208,6 +208,11 @@ protected void doStop() {
 		}
 	}
 
+	@Override
+	public String getComponentType() {
+		return "reactive-streams";
+	}
+
 	private static final class MessageHandlerSubscriber
 			implements CoreSubscriber<Message<?>>, Disposable, Lifecycle {
 

spring-integration-core/src/main/java/org/springframework/integration/gateway/GatewayProxyFactoryBean.java

@@ -1055,6 +1055,11 @@ public void destroy() {
 		this.gatewayMap.values().forEach(MethodInvocationGateway::destroy);
 	}
 
+	@Override
+	public String getComponentType() {
+		return "gateway-proxy-factory";
+	}
+
 	private static final class MethodInvocationGateway extends MessagingGatewaySupport {
 
 		private Expression receiveTimeoutExpression;

spring-integration-core/src/test/java/org/springframework/integration/endpoint/MessageProducerSupportTests.java

@@ -202,6 +202,11 @@ protected void doStop() {
 			this.stopped.set(true);
 		}
 
+		@Override
+		public String getComponentType() {
+			return "custom-endpoint";
+		}
+
 	}
 
 }

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

@@ -167,7 +167,7 @@ public ApplicationEventPublisher getApplicationEventPublisher() {
 
 	@Override
 	public String getComponentType() {
-		return "connection";
+		return "connection-factory";
 	}
 
 	/**

spring-integration-jmx/src/test/java/org/springframework/integration/monitor/MBeanExporterIntegrationTests.java

@@ -302,6 +302,11 @@ protected void doStart() {
 		protected void doStop() {
 		}
 
+		@Override
+		public String getComponentType() {
+			return "bogus-endpoint";
+		}
+
 	}
 
 	public static class DateFactoryBean implements FactoryBean<Date> {