[camel] branch main updated: Update SpringTransactionPolicy.java (#6467)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 25b49c1a Update SpringTransactionPolicy.java (#6467)
25b49c1a is described below

commit 25b49c1ae970b4bc2cf6bbfb9e02a59895e4d2c0
Author: Benjamin Graf <gr...@users.noreply.github.com>
AuthorDate: Wed Nov 24 06:59:07 2021 +0100

    Update SpringTransactionPolicy.java (#6467)
---
 .../org/apache/camel/spring/spi/SpringTransactionPolicy.java | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/components/camel-spring/src/main/java/org/apache/camel/spring/spi/SpringTransactionPolicy.java b/components/camel-spring/src/main/java/org/apache/camel/spring/spi/SpringTransactionPolicy.java
index d264ad4..505d0fa 100644
--- a/components/camel-spring/src/main/java/org/apache/camel/spring/spi/SpringTransactionPolicy.java
+++ b/components/camel-spring/src/main/java/org/apache/camel/spring/spi/SpringTransactionPolicy.java
@@ -38,6 +38,7 @@ import org.springframework.transaction.support.TransactionTemplate;
 public class SpringTransactionPolicy implements TransactedPolicy {
     private static final Logger LOG = LoggerFactory.getLogger(SpringTransactionPolicy.class);
     private TransactionTemplate template;
+    private String name;
     private String propagationBehaviorName;
     private PlatformTransactionManager transactionManager;
 
@@ -133,6 +134,9 @@ public class SpringTransactionPolicy implements TransactedPolicy {
         if (template == null) {
             ObjectHelper.notNull(transactionManager, "transactionManager");
             template = new TransactionTemplate(transactionManager);
+            if (name != null) {
+                template.setName(name);
+            }
             if (propagationBehaviorName != null) {
                 template.setPropagationBehaviorName(propagationBehaviorName);
             }
@@ -152,6 +156,14 @@ public class SpringTransactionPolicy implements TransactedPolicy {
         return transactionManager;
     }
 
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getName() {
+        return name;
+    }
+
     public void setPropagationBehaviorName(String propagationBehaviorName) {
         this.propagationBehaviorName = propagationBehaviorName;
     }