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

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

commit 0b0b4b6b72adeffbe0fe98178b8cf5e342849147
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Jan 22 17:24:15 2024 +0100

    CAMEL-19749: EIPs should make it easy to use together with variables.
---
 .../api/management/mbean/ManagedSendDynamicProcessorMBean.java |  6 ++++++
 .../camel/api/management/mbean/ManagedSendProcessorMBean.java  |  6 ++++++
 .../camel/management/mbean/ManagedSendDynamicProcessor.java    | 10 ++++++++++
 .../apache/camel/management/mbean/ManagedSendProcessor.java    | 10 ++++++++++
 4 files changed, 32 insertions(+)

diff --git 
a/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendDynamicProcessorMBean.java
 
b/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendDynamicProcessorMBean.java
index 36a0333acab..11224a5884d 100644
--- 
a/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendDynamicProcessorMBean.java
+++ 
b/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendDynamicProcessorMBean.java
@@ -27,6 +27,12 @@ public interface ManagedSendDynamicProcessorMBean extends 
ManagedProcessorMBean,
                       mask = true)
     String getUri();
 
+    @ManagedAttribute(description = "Variable as the source for the message 
body to send")
+    String getVariableSend();
+
+    @ManagedAttribute(description = "Variable to store the received message 
body (only body, not headers)")
+    String getVariableReceive();
+
     @ManagedAttribute(description = "Message Exchange Pattern")
     String getMessageExchangePattern();
 
diff --git 
a/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java
 
b/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java
index 580841fe5a3..e0e31150032 100644
--- 
a/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java
+++ 
b/core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedSendProcessorMBean.java
@@ -26,6 +26,12 @@ public interface ManagedSendProcessorMBean extends 
ManagedProcessorMBean, Manage
     @ManagedAttribute(description = "Destination as Endpoint URI", mask = true)
     String getDestination();
 
+    @ManagedAttribute(description = "Variable as the source for the message 
body to send")
+    String getVariableSend();
+
+    @ManagedAttribute(description = "Variable to store the received message 
body (only body, not headers)")
+    String getVariableReceive();
+
     @ManagedAttribute(description = "Message Exchange Pattern")
     String getMessageExchangePattern();
 
diff --git 
a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java
 
b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java
index dbe317f7ba0..f3cd46cb9e9 100644
--- 
a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java
+++ 
b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendDynamicProcessor.java
@@ -81,6 +81,16 @@ public class ManagedSendDynamicProcessor extends 
ManagedProcessor implements Man
         return uri;
     }
 
+    @Override
+    public String getVariableSend() {
+        return processor.getVariableSend();
+    }
+
+    @Override
+    public String getVariableReceive() {
+        return processor.getVariableReceive();
+    }
+
     @Override
     public String getMessageExchangePattern() {
         if (processor.getPattern() != null) {
diff --git 
a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java
 
b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java
index 51706e5a44d..467805c46cf 100644
--- 
a/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java
+++ 
b/core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedSendProcessor.java
@@ -74,6 +74,16 @@ public class ManagedSendProcessor extends ManagedProcessor 
implements ManagedSen
         return destination;
     }
 
+    @Override
+    public String getVariableSend() {
+        return processor.getVariableSend();
+    }
+
+    @Override
+    public String getVariableReceive() {
+        return processor.getVariableReceive();
+    }
+
     @Override
     public String getMessageExchangePattern() {
         if (processor.getPattern() != null) {

Reply via email to