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) {