From ab0168261d10f3b78589feabdd67276bb974b9c8 Mon Sep 17 00:00:00 2001 From: smallbun <30397655+leshalv@users.noreply.github.com> Date: Thu, 26 Sep 2024 17:51:11 +0800 Subject: [PATCH 1/4] Add getBeforePublishPostProcessors method --- .../amqp/rabbit/core/RabbitTemplate.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java index 5d2894c96c..004251120e 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java @@ -632,6 +632,17 @@ public void setBeanFactory(BeanFactory beanFactory) throws BeansException { this.evaluationContext.setBeanResolver(new BeanFactoryResolver(beanFactory)); this.evaluationContext.addPropertyAccessor(new MapAccessor()); } + + /** + * Return configured before post {@link MessagePostProcessor}s or {@code null}. + * @return configured before post {@link MessagePostProcessor}s or {@code null}. + */ + @Nullable + public Collection getBeforePublishPostProcessors() { + return this.beforePublishPostProcessors != null + ? Collections.unmodifiableCollection(this.beforePublishPostProcessors) + : null; + } /** * Set {@link MessagePostProcessor}s that will be invoked immediately before invoking From b182983fa6aec32a63da4c18b5dceb49b7ced81f Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 8 Oct 2024 15:48:54 -0400 Subject: [PATCH 2/4] Add `@since 3.2` to a new public API --- .../org/springframework/amqp/rabbit/core/RabbitTemplate.java | 1 + 1 file changed, 1 insertion(+) diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java index 004251120e..fd24ea8610 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java @@ -636,6 +636,7 @@ public void setBeanFactory(BeanFactory beanFactory) throws BeansException { /** * Return configured before post {@link MessagePostProcessor}s or {@code null}. * @return configured before post {@link MessagePostProcessor}s or {@code null}. + * @since 3.2 */ @Nullable public Collection getBeforePublishPostProcessors() { From 437dcc39589eb3981c051a44c6ab36178fad35f1 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 8 Oct 2024 15:52:32 -0400 Subject: [PATCH 3/4] Remove trailing whitespaces in empty line --- .../org/springframework/amqp/rabbit/core/RabbitTemplate.java | 1 - 1 file changed, 1 deletion(-) diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java index fd24ea8610..a7a91c3fc7 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java @@ -632,7 +632,6 @@ public void setBeanFactory(BeanFactory beanFactory) throws BeansException { this.evaluationContext.setBeanResolver(new BeanFactoryResolver(beanFactory)); this.evaluationContext.addPropertyAccessor(new MapAccessor()); } - /** * Return configured before post {@link MessagePostProcessor}s or {@code null}. * @return configured before post {@link MessagePostProcessor}s or {@code null}. From cf8cb8e54a78dd62c6ac5643be3b1c571152f3e3 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 8 Oct 2024 15:53:09 -0400 Subject: [PATCH 4/4] And blank line after the method --- .../org/springframework/amqp/rabbit/core/RabbitTemplate.java | 1 + 1 file changed, 1 insertion(+) diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java index a7a91c3fc7..3de6bbe7fb 100644 --- a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java +++ b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java @@ -632,6 +632,7 @@ public void setBeanFactory(BeanFactory beanFactory) throws BeansException { this.evaluationContext.setBeanResolver(new BeanFactoryResolver(beanFactory)); this.evaluationContext.addPropertyAccessor(new MapAccessor()); } + /** * Return configured before post {@link MessagePostProcessor}s or {@code null}. * @return configured before post {@link MessagePostProcessor}s or {@code null}.