From 1b61509bded8cd26d2fe7fbcb645703f2932bce8 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Wed, 26 Nov 2008 02:03:57 +0000 Subject: [PATCH] Added some JavaDoc. --- .../integration/jms/JmsOutboundGateway.java | 23 +++++++++++++++++-- 1 file changed, 21 insertions(+), 2 deletions(-) diff --git a/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java b/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java index e658cc9ba6..59d30ae8a2 100644 --- a/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java +++ b/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/JmsOutboundGateway.java @@ -209,10 +209,28 @@ public class JmsOutboundGateway extends AbstractReplyProducingMessageHandler imp this.headerMapper = headerMapper; } + /** + * This property will take effect if no custom {@link MessageConverter} + * has been provided to the {@link #setMessageConverter(MessageConverter)} + * method. In that case, a {@link HeaderMappingMessageConverter} will be + * used by default, and this value will be passed along to that converter's + * 'extractIntegrationMessagePayload' property. + * + * @see HeaderMappingMessageConverter#setExtractIntegrationMessagePayload(boolean) + */ public void setExtractRequestPayload(boolean extractRequestPayload) { this.extractRequestPayload = extractRequestPayload; } + /** + * This property will take effect if no custom {@link MessageConverter} + * has been provided to the {@link #setMessageConverter(MessageConverter)} + * method. In that case, a {@link HeaderMappingMessageConverter} will be + * used by default, and this value will be passed along to that converter's + * 'extractJmsMessageBody' property. + * + * @see HeaderMappingMessageConverter#setExtractJmsMessageBody(boolean) + */ public void setExtractReplyPayload(boolean extractReplyPayload) { this.extractReplyPayload = extractReplyPayload; } @@ -273,9 +291,10 @@ public class JmsOutboundGateway extends AbstractReplyProducingMessageHandler imp } final Message requestMessage = MessageBuilder.fromMessage(message).build(); try { - javax.jms.Message jmsReply = JmsOutboundGateway.this.sendAndReceive(requestMessage); + javax.jms.Message jmsReply = this.sendAndReceive(requestMessage); if (jmsReply == null) { - throw new MessageTimeoutException(message, "failed to receive JMS response within timeout of: " + this.receiveTimeout + "ms"); + throw new MessageTimeoutException(message, + "failed to receive JMS response within timeout of: " + this.receiveTimeout + "ms"); } Object result = this.messageConverter.fromMessage(jmsReply); replyMessageHolder.set(result);