Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

populating component metadata with type

Browse Source
This commit is contained in:
Mark Fisher
2010-03-11 20:13:07 +00:00
parent 1afd8751eb
commit 7073397739
4 changed files with 23 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
org.springframework.integration/src/main/java/org/springframework/integration/filter/MessageFilter.java
View File

@@ -22,6 +22,7 @@ import org.springframework.integration.handler.AbstractReplyProducingMessageHand
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.integration.message.MessageRejectedException;
import org.springframework.integration.selector.MessageSelector;
import org.springframework.integration.support.ComponentMetadata;
import org.springframework.util.Assert;
/**
@@ -37,9 +38,6 @@ import org.springframework.util.Assert;
*/
public class MessageFilter extends AbstractReplyProducingMessageHandler {
public static final String COMPONENT_TYPE_LABEL = "filter";
private final MessageSelector selector;
private volatile boolean throwExceptionOnRejection;
@@ -84,6 +82,11 @@ public class MessageFilter extends AbstractReplyProducingMessageHandler {
this.discardChannel = discardChannel;
}
@Override
protected void populateComponentMetadata(ComponentMetadata metadata) {
metadata.setComponentType("filter");
}
@Override
protected Object handleRequestMessage(Message<?> message) {
if (this.selector.accept(message)) {

7
org.springframework.integration/src/main/java/org/springframework/integration/handler/BridgeHandler.java
View File

@@ -17,6 +17,7 @@
package org.springframework.integration.handler;
import org.springframework.integration.core.Message;
import org.springframework.integration.support.ComponentMetadata;
import org.springframework.util.Assert;
/**
@@ -35,8 +36,10 @@ import org.springframework.util.Assert;
*/
public class BridgeHandler extends AbstractReplyProducingMessageHandler {
public static final String COMPONENT_TYPE_LABEL = "bridge";
@Override
protected void populateComponentMetadata(ComponentMetadata metadata) {
metadata.setComponentType("bridge");
}
@Override
protected Object handleRequestMessage(Message<?> requestMessage) {

8
org.springframework.integration/src/main/java/org/springframework/integration/handler/LoggingHandler.java
View File

@@ -20,6 +20,7 @@ import java.io.PrintWriter;
import java.io.StringWriter;
import org.springframework.integration.core.Message;
import org.springframework.integration.support.ComponentMetadata;
import org.springframework.util.StringUtils;
/**
@@ -35,8 +36,6 @@ public class LoggingHandler extends AbstractMessageHandler {
private static enum Level { FATAL, ERROR, WARN, INFO, DEBUG, TRACE }
public static final String COMPONENT_TYPE_LABEL = "logging-channel-adapter";
private boolean shouldLogFullMessage;
@@ -66,6 +65,11 @@ public class LoggingHandler extends AbstractMessageHandler {
this.shouldLogFullMessage = shouldLogFullMessage;
}
@Override
protected void populateComponentMetadata(ComponentMetadata metadata) {
metadata.setComponentType("logging-channel-adapter");
}
@Override
protected void handleMessageInternal(Message<?> message) throws Exception {
Object logMessage = (this.shouldLogFullMessage) ? message : message.getPayload();

9
org.springframework.integration/src/main/java/org/springframework/integration/handler/ServiceActivatingHandler.java
View File

@@ -21,15 +21,13 @@ import java.lang.reflect.Method;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.core.Message;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.support.ComponentMetadata;
/**
* @author Mark Fisher
*/
public class ServiceActivatingHandler extends AbstractReplyProducingMessageHandler {
public static final String COMPONENT_TYPE_LABEL = "service-activator";
private final MethodInvokingMessageProcessor processor;
@@ -46,6 +44,11 @@ public class ServiceActivatingHandler extends AbstractReplyProducingMessageHandl
}
@Override
protected void populateComponentMetadata(ComponentMetadata metadata) {
metadata.setComponentType("service-activator");
}
@Override
protected Object handleRequestMessage(Message<?> message) {
try {