Skip to content

Commit 3520721

Browse files
committed
GH-2978: Expose some getters for AbstractMessageListenerContainer
Fixes: #2978 Issue link: #2978 **Auto-cherry-pick to `3.2.x` & `3.1.x`**
1 parent 0e24d40 commit 3520721

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
@@ -462,13 +462,21 @@ protected void checkMessageListener(Object listener) {
462462
/**
463463
* Set an ErrorHandler to be invoked in case of any uncaught exceptions thrown while processing a Message. By
464464
* default, a {@link ConditionalRejectingErrorHandler} with its default list of fatal exceptions will be used.
465-
*
466465
* @param errorHandler The error handler.
467466
*/
468467
public void setErrorHandler(ErrorHandler errorHandler) {
469468
this.errorHandler = errorHandler;
470469
}
471470

471+
/**
472+
* Return the {@link ErrorHandler}.
473+
* @return the {@link ErrorHandler}
474+
* @since 3.1.9
475+
*/
476+
public ErrorHandler getErrorHandler() {
477+
return this.errorHandler;
478+
}
479+
472480
/**
473481
* Determine whether the container should de-batch batched
474482
* messages (true) or call the listener with the batch (false). Default: true.
@@ -1165,7 +1173,12 @@ public void setMessageAckListener(MessageAckListener messageAckListener) {
11651173
this.messageAckListener = messageAckListener;
11661174
}
11671175

1168-
protected MessageAckListener getMessageAckListener() {
1176+
/**
1177+
* Return the {@link MessageAckListener}.
1178+
* @return the {@link MessageAckListener}
1179+
* @since 3.1.9
1180+
*/
1181+
public MessageAckListener getMessageAckListener() {
11691182
return this.messageAckListener;
11701183
}
11711184

0 commit comments

Comments
 (0)