1
1
/*
2
- * Copyright 2002-2023 the original author or authors.
2
+ * Copyright 2002-2025 the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
102
102
* (i.e. after your business logic executed but before the JMS part got committed),
103
103
* so duplicate message detection is just there to cover a corner case.
104
104
* <li>Or wrap your <i>entire processing with an XA transaction</i>, covering the
105
- * reception of the JMS message as well as the execution of the business logic in
105
+ * receipt of the JMS message as well as the execution of the business logic in
106
106
* your message listener (including database operations etc). This is only
107
107
* supported by {@link DefaultMessageListenerContainer}, through specifying
108
108
* an external "transactionManager" (typically a
@@ -152,7 +152,8 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
152
152
implements MessageListenerContainer {
153
153
154
154
private static final boolean micrometerJakartaPresent = ClassUtils .isPresent (
155
- "io.micrometer.jakarta9.instrument.jms.JmsInstrumentation" , AbstractMessageListenerContainer .class .getClassLoader ());
155
+ "io.micrometer.jakarta9.instrument.jms.JmsInstrumentation" ,
156
+ AbstractMessageListenerContainer .class .getClassLoader ());
156
157
157
158
@ Nullable
158
159
private volatile Object destination ;
@@ -170,14 +171,14 @@ public abstract class AbstractMessageListenerContainer extends AbstractJmsListen
170
171
@ Nullable
171
172
private String subscriptionName ;
172
173
174
+ private boolean pubSubNoLocal = false ;
175
+
173
176
@ Nullable
174
177
private Boolean replyPubSubDomain ;
175
178
176
179
@ Nullable
177
180
private QosSettings replyQosSettings ;
178
181
179
- private boolean pubSubNoLocal = false ;
180
-
181
182
@ Nullable
182
183
private MessageConverter messageConverter ;
183
184
@@ -500,12 +501,7 @@ public void setReplyPubSubDomain(boolean replyPubSubDomain) {
500
501
*/
501
502
@ Override
502
503
public boolean isReplyPubSubDomain () {
503
- if (this .replyPubSubDomain != null ) {
504
- return this .replyPubSubDomain ;
505
- }
506
- else {
507
- return isPubSubDomain ();
508
- }
504
+ return (this .replyPubSubDomain != null ? this .replyPubSubDomain : isPubSubDomain ());
509
505
}
510
506
511
507
/**
0 commit comments