File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
support/src/main/java/org/springframework/ws/transport/jms Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -92,6 +92,8 @@ void setPostProcessor(MessagePostProcessor postProcessor) {
92
92
this .postProcessor = postProcessor ;
93
93
}
94
94
95
+
96
+
95
97
/** Returns the request message for this connection. Returns either a {@link BytesMessage} or a {@link TextMessage}. */
96
98
public Message getRequestMessage () {
97
99
return requestMessage ;
@@ -179,7 +181,11 @@ else if (requestMessage instanceof TextMessage) {
179
181
else {
180
182
throw new IllegalStateException ("Unknown request message type [" + requestMessage + "]" );
181
183
}
182
- responseMessage .setJMSCorrelationID (requestMessage .getJMSMessageID ());
184
+ String correlation = requestMessage .getJMSCorrelationID ();
185
+ if (correlation == null ) {
186
+ correlation = requestMessage .getJMSMessageID ();
187
+ }
188
+ responseMessage .setJMSCorrelationID (correlation );
183
189
}
184
190
catch (JMSException ex ) {
185
191
throw new JmsTransportException ("Could not create response message" , ex );
You can’t perform that action at this time.
0 commit comments