Skip to content

Commit 1667ece

Browse files
artembilanspring-builds
authored andcommitted
GH-2978: Expose some getters for AbstractMessageListenerContainer
Fixes: #2978 Issue link: #2978 (cherry picked from commit 3520721)
1 parent 5a71263 commit 1667ece

File tree

1 file changed

+15
-2
lines changed

1 file changed

+15
-2
lines changed

spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/AbstractMessageListenerContainer.java

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -466,13 +466,21 @@ public MessageListener getMessageListener() {
466466
/**
467467
* Set an ErrorHandler to be invoked in case of any uncaught exceptions thrown while processing a Message. By
468468
* default, a {@link ConditionalRejectingErrorHandler} with its default list of fatal exceptions will be used.
469-
*
470469
* @param errorHandler The error handler.
471470
*/
472471
public void setErrorHandler(ErrorHandler errorHandler) {
473472
this.errorHandler = errorHandler;
474473
}
475474

475+
/**
476+
* Return the {@link ErrorHandler}.
477+
* @return the {@link ErrorHandler}
478+
* @since 3.1.9
479+
*/
480+
public ErrorHandler getErrorHandler() {
481+
return this.errorHandler;
482+
}
483+
476484
/**
477485
* Determine whether the container should de-batch batched
478486
* messages (true) or call the listener with the batch (false). Default: true.
@@ -1161,7 +1169,12 @@ public void setMessageAckListener(MessageAckListener messageAckListener) {
11611169
this.messageAckListener = messageAckListener;
11621170
}
11631171

1164-
protected MessageAckListener getMessageAckListener() {
1172+
/**
1173+
* Return the {@link MessageAckListener}.
1174+
* @return the {@link MessageAckListener}
1175+
* @since 3.1.9
1176+
*/
1177+
public MessageAckListener getMessageAckListener() {
11651178
return this.messageAckListener;
11661179
}
11671180

0 commit comments

Comments
 (0)