Skip to content

Commit 5e2c557

Browse files
committed
GH-1352: Fix Previous Commit
1 parent cc698f5 commit 5e2c557

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/AbstractRabbitListenerContainerFactory.java

+1
Original file line numberDiff line numberDiff line change
@@ -362,6 +362,7 @@ public C createListenerContainer(RabbitListenerEndpoint endpoint) {
362362
.acceptIfNotNull(this.transactionManager, instance::setTransactionManager)
363363
.acceptIfNotNull(this.prefetchCount, instance::setPrefetchCount)
364364
.acceptIfNotNull(this.globalQos, instance::setGlobalQos)
365+
.acceptIfNotNull(getDefaultRequeueRejected(), instance::setDefaultRequeueRejected)
365366
.acceptIfNotNull(this.adviceChain, instance::setAdviceChain)
366367
.acceptIfNotNull(this.recoveryBackOff, instance::setRecoveryBackOff)
367368
.acceptIfNotNull(this.mismatchedQueuesFatal, instance::setMismatchedQueuesFatal)

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/config/BaseRabbitListenerContainerFactory.java

+8-3
Original file line numberDiff line numberDiff line change
@@ -60,11 +60,18 @@ public void setDefaultRequeueRejected(Boolean requeueRejected) {
6060
this.defaultRequeueRejected = requeueRejected;
6161
}
6262

63+
/**
64+
* Return the defaultRequeueRejected.
65+
* @return the defaultRequeueRejected.
66+
*/
67+
protected Boolean getDefaultRequeueRejected() {
68+
return this.defaultRequeueRejected;
69+
}
70+
6371
/**
6472
* Set post processors that will be applied before sending replies; added to each
6573
* message listener adapter.
6674
* @param postProcessors the post processors.
67-
* @since 2.0.3
6875
* @see AbstractAdaptableMessageListener#setBeforeSendReplyPostProcessors(MessagePostProcessor...)
6976
*/
7077
public void setBeforeSendReplyPostProcessors(MessagePostProcessor... postProcessors) {
@@ -77,7 +84,6 @@ public void setBeforeSendReplyPostProcessors(MessagePostProcessor... postProcess
7784
* Set a {@link RetryTemplate} to use when sending replies; added to each message
7885
* listener adapter.
7986
* @param retryTemplate the template.
80-
* @since 2.0.6
8187
* @see #setReplyRecoveryCallback(RecoveryCallback)
8288
* @see AbstractAdaptableMessageListener#setRetryTemplate(RetryTemplate)
8389
*/
@@ -90,7 +96,6 @@ public void setRetryTemplate(RetryTemplate retryTemplate) {
9096
* message listener adapter. Only used if a {@link #setRetryTemplate(RetryTemplate)
9197
* retryTemplate} is provided.
9298
* @param recoveryCallback the recovery callback.
93-
* @since 2.0.6
9499
* @see #setRetryTemplate(RetryTemplate)
95100
* @see AbstractAdaptableMessageListener#setRecoveryCallback(RecoveryCallback)
96101
*/

0 commit comments

Comments
 (0)