populating component metadata with type

This commit is contained in:
Mark Fisher
2010-03-11 20:14:15 +00:00
parent 7073397739
commit 6669dd21dd
4 changed files with 21 additions and 10 deletions

View File

@@ -26,6 +26,7 @@ import org.springframework.integration.core.MessageHeaders;
import org.springframework.integration.handler.AbstractMessageHandler;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.integration.support.ComponentMetadata;
/**
* Base class for Message Routers.
@@ -34,9 +35,6 @@ import org.springframework.integration.message.MessageDeliveryException;
*/
public abstract class AbstractMessageRouter extends AbstractMessageHandler {
public static final String COMPONENT_TYPE_LABEL = "router";
private volatile MessageChannel defaultOutputChannel;
private volatile boolean resolutionRequired;
@@ -98,6 +96,11 @@ public abstract class AbstractMessageRouter extends AbstractMessageHandler {
this.applySequence = applySequence;
}
@Override
protected void populateComponentMetadata(ComponentMetadata metadata) {
metadata.setComponentType("router");
}
@Override
protected void handleMessageInternal(Message<?> message) {
boolean sent = false;

View File

@@ -27,6 +27,7 @@ import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.core.Message;
import org.springframework.integration.core.MessageChannel;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.integration.support.ComponentMetadata;
import org.springframework.util.Assert;
/**
@@ -59,9 +60,6 @@ import org.springframework.util.Assert;
*/
public class RecipientListRouter extends AbstractMessageRouter implements InitializingBean {
public static final String COMPONENT_TYPE_LABEL = "recipient-list-router";
private volatile Map<MessageSelector, ? extends Collection<MessageChannel>> channelMap;
@@ -90,6 +88,11 @@ public class RecipientListRouter extends AbstractMessageRouter implements Initia
this.channelMap = channelMap;
}
@Override
protected void populateComponentMetadata(ComponentMetadata metadata) {
metadata.setComponentType("recipient-list-router");
}
@Override
public final void onInit() {
Assert.notEmpty(this.channelMap, "a non-empty channel map is required");

View File

@@ -18,6 +18,7 @@ package org.springframework.integration.transformer;
import org.springframework.integration.core.Message;
import org.springframework.integration.handler.AbstractReplyProducingMessageHandler;
import org.springframework.integration.support.ComponentMetadata;
import org.springframework.util.Assert;
/**
@@ -29,9 +30,6 @@ import org.springframework.util.Assert;
*/
public class MessageTransformingHandler extends AbstractReplyProducingMessageHandler {
public static final String COMPONENT_TYPE_LABEL = "transformer";
private final Transformer transformer;
@@ -45,6 +43,11 @@ public class MessageTransformingHandler extends AbstractReplyProducingMessageHan
}
@Override
protected void populateComponentMetadata(ComponentMetadata metadata) {
metadata.setComponentType("transformer");
}
@Override
protected Object handleRequestMessage(Message<?> message) {
try {

View File

@@ -267,7 +267,9 @@ public class GatewayProxyFactoryBeanTests {
DirectChannel channel = new DirectChannel();
channel.setBeanName("testChannel");
channel.afterPropertiesSet();
EventDrivenConsumer consumer = new EventDrivenConsumer(channel, new BridgeHandler());
BridgeHandler bridgeHandler = new BridgeHandler();
bridgeHandler.afterPropertiesSet();
EventDrivenConsumer consumer = new EventDrivenConsumer(channel, bridgeHandler);
consumer.setBeanName("testBridge");
consumer.afterPropertiesSet();
consumer.start();