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

avoiding NPE in AmqpOutboundEndpoint

Browse Source
This commit is contained in:
Mark Fisher
2011-07-27 16:38:27 -04:00
parent cd1c4b1c45
commit 57f6c3e0ab
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-integration-amqp/src/main/java/org/springframework/integration/amqp/outbound/AmqpOutboundEndpoint.java
View File

@@ -124,6 +124,9 @@ public class AmqpOutboundEndpoint extends AbstractReplyProducingMessageHandler {
this.headerMapper.fromHeaders(requestMessage.getHeaders(), amqpMessageProperties);
org.springframework.amqp.core.Message amqpMessage = converter.toMessage(requestMessage.getPayload(), amqpMessageProperties);
org.springframework.amqp.core.Message amqpReplyMessage = this.amqpTemplate.sendAndReceive(this.exchangeName, routingKey, amqpMessage);
if (amqpReplyMessage == null) {
return null;
}
Object replyObject = converter.fromMessage(amqpReplyMessage);
MessageBuilder<?> builder = (replyObject instanceof Message)
? MessageBuilder.fromMessage((Message<?>) replyObject)