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

INT-1624 added errorChannel property to MessageProducerSupport, if not null, errorMessages will be sent there instead of being thrown to the caller

Browse Source
This commit is contained in:
Mark Fisher
2010-11-16 00:34:02 -05:00
parent b86c27a769
commit 9c2ddf99b5
1 changed files with 22 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -18,11 +18,13 @@ package org.springframework.integration.endpoint;
import org.springframework.integration.Message;
import org.springframework.integration.MessageChannel;
import org.springframework.integration.MessageDeliveryException;
import org.springframework.integration.MessagingException;
import org.springframework.integration.core.MessageProducer;
import org.springframework.integration.core.MessagingTemplate;
import org.springframework.integration.history.MessageHistory;
import org.springframework.integration.history.TrackableComponent;
import org.springframework.integration.message.ErrorMessage;
import org.springframework.util.Assert;
/**
@@ -35,6 +37,8 @@ public abstract class MessageProducerSupport extends AbstractEndpoint implements
private volatile MessageChannel outputChannel;
private volatile MessageChannel errorChannel;
private volatile boolean shouldTrack = false;
private final MessagingTemplate messagingTemplate = new MessagingTemplate();
@@ -44,6 +48,10 @@ public abstract class MessageProducerSupport extends AbstractEndpoint implements
this.outputChannel = outputChannel;
}
public void setErrorChannel(MessageChannel errorChannel) {
this.errorChannel = errorChannel;
}
public void setSendTimeout(long sendTimeout) {
this.messagingTemplate.setSendTimeout(sendTimeout);
}
@@ -80,7 +88,20 @@ public abstract class MessageProducerSupport extends AbstractEndpoint implements
if (this.shouldTrack) {
message = MessageHistory.write(message, this);
}
this.messagingTemplate.send(this.outputChannel, message);
try {
this.messagingTemplate.send(this.outputChannel, message);
}
catch (Exception e) {
if (this.errorChannel != null) {
this.messagingTemplate.send(this.errorChannel, new ErrorMessage(e));
}
else if (e instanceof RuntimeException) {
throw (RuntimeException) e;
}
else {
throw new MessageDeliveryException(message, "failed to send message", e);
}
}
}
}