diff --git a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/StreamSendException.java b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/StreamSendException.java index cd6e6bc7..de11d4ab 100644 --- a/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/StreamSendException.java +++ b/spring-rabbit-stream/src/main/java/org/springframework/rabbit/stream/producer/StreamSendException.java @@ -40,4 +40,12 @@ public class StreamSendException extends AmqpException { this.confirmationCode = code; } + /** + * Return the confirmation code, if available. + * @return the code. + */ + public int getConfirmationCode() { + return this.confirmationCode; + } + }