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

INT-442

Browse Source
This commit is contained in:
Mark Fisher
2008-10-28 19:09:40 +00:00
parent b10afab6f4
commit ca08c18946
2 changed files with 12 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/AbstractRemotingOutboundGateway.java
View File

@@ -22,6 +22,7 @@ import org.springframework.integration.consumer.AbstractReplyProducingMessageCon
import org.springframework.integration.consumer.ReplyMessageHolder;
import org.springframework.integration.core.Message;
import org.springframework.integration.core.MessageChannel;
import org.springframework.integration.message.MessageBuilder;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.remoting.RemoteAccessException;
@@ -52,9 +53,14 @@ public abstract class AbstractRemotingOutboundGateway extends AbstractReplyProdu
@Override
public final void onMessage(Message<?> message, ReplyMessageHolder replyHolder) {
this.verifySerializability(message);
if (!(message.getPayload() instanceof Serializable)) {
throw new MessageHandlingException(message,
this.getClass().getName() + " expects a Serializable payload type " +
"but encountered [" + message.getPayload().getClass().getName() + "]");
}
Message<?> requestMessage = MessageBuilder.fromMessage(message).build();
try {
Message<?> reply = this.handlerProxy.handle(message);
Message<?> reply = this.handlerProxy.handle(requestMessage);
if (reply != null) {
replyHolder.set(reply);
}
@@ -64,21 +70,4 @@ public abstract class AbstractRemotingOutboundGateway extends AbstractReplyProdu
}
}
private void verifySerializability(Message<?> message) {
if (!(message.getPayload() instanceof Serializable)) {
throw new MessageHandlingException(message,
this.getClass().getName() + " expects a Serializable payload type " +
"but encountered '" + message.getPayload().getClass().getName() + "'");
}
for (String headerName : message.getHeaders().keySet()) {
Object attribute = message.getHeaders().get(headerName);
if (!(attribute instanceof Serializable)) {
throw new MessageHandlingException(message,
this.getClass().getName() + " expects Serializable attribute types " +
"but encountered '" + attribute.getClass().getName() + "' for the attribute '" +
headerName + "'");
}
}
}
}