This is an automated email from the ASF dual-hosted git repository.
acosentino 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 250ca2949c3 CAMEL-18287 - Camel-AWS Eventbridge: Support operation
putEvents to send custom event to Eventbridge
250ca2949c3 is described below
commit 250ca2949c3a11c7fad53f8ba5472fb2af0adb6c
Author: Andrea Cosentino <[email protected]>
AuthorDate: Fri Jul 22 14:07:22 2022 +0200
CAMEL-18287 - Camel-AWS Eventbridge: Support operation putEvents to send
custom event to Eventbridge
---
.../src/main/docs/aws2-eventbridge-component.adoc | 21 +++++++++++++++++++++
1 file changed, 21 insertions(+)
diff --git
a/components/camel-aws/camel-aws2-eventbridge/src/main/docs/aws2-eventbridge-component.adoc
b/components/camel-aws/camel-aws2-eventbridge/src/main/docs/aws2-eventbridge-component.adoc
index 1a9c664d04b..5744f981e38 100644
---
a/components/camel-aws/camel-aws2-eventbridge/src/main/docs/aws2-eventbridge-component.adoc
+++
b/components/camel-aws/camel-aws2-eventbridge/src/main/docs/aws2-eventbridge-component.adoc
@@ -82,6 +82,7 @@ Camel-AWS2-Eventbridge component provides the following
operation on the produce
- describeRule
- listTargetsByRule
- listRuleNamesByTarget
+- putEvent
- PutRule: this operation create a rule related to an eventbus
@@ -261,6 +262,26 @@ this operation will return a list of targets associated
with the firstrule rule.
this operation will return a list of rule associated with a target.
+- PutEvent: this operation will send an event to the Servicebus
+
+[source,java]
+--------------------------------------------------------------------------------
+ from("direct:start").process(new Processor() {
+
+ @Override
+ public void process(Exchange exchange) throws Exception {
+
exchange.getIn().setHeader(EventbridgeConstants.EVENT_RESOURCES_ARN,
"arn:aws:sqs:eu-west-1:780410022472:camel-connector-test");
+ exchange.getIn().setHeader(EventbridgeConstants.EVENT_SOURCE,
"com.pippo");
+
exchange.getIn().setHeader(EventbridgeConstants.EVENT_DETAIL_TYPE, "peppe");
+ exchange.getIn().setBody("Test Event");
+ }
+ })
+ .to("aws2-eventbridge://test?operation=putEvent")
+ .to("mock:result");
+--------------------------------------------------------------------------------
+
+this operation will return a list of entries with related ID sent to
servicebus.
+
== Updating the rule
To update a rule you'll need to perform the putRule operation again.