You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/09/23 06:49:04 UTC
[camel] 02/06: Camel-AWS2-Eventbridge: Support eventbusNameOrArn
like the other AWS* components
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit bf73081574dda93fd9daef556aca66b616480a64
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Sep 23 08:33:08 2020 +0200
Camel-AWS2-Eventbridge: Support eventbusNameOrArn like the other AWS* components
---
.../apache/camel/component/aws2/eventbridge/EventbridgeComponent.java | 1 +
.../eventbridge/integration/EventbridgePutRuleIntegrationTest.java | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeComponent.java b/components/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeComponent.java
index 4a3d053..d8d0ec4 100644
--- a/components/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeComponent.java
+++ b/components/camel-aws2-eventbridge/src/main/java/org/apache/camel/component/aws2/eventbridge/EventbridgeComponent.java
@@ -60,6 +60,7 @@ public class EventbridgeComponent extends DefaultComponent {
}
EventbridgeConfiguration configuration
= this.configuration != null ? this.configuration.copy() : new EventbridgeConfiguration();
+ configuration.setEventbusName(remaining);
EventbridgeEndpoint endpoint = new EventbridgeEndpoint(uri, this, configuration);
setProperties(endpoint, parameters);
if (endpoint.getConfiguration().isAutoDiscoverClient()) {
diff --git a/components/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/integration/EventbridgePutRuleIntegrationTest.java b/components/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/integration/EventbridgePutRuleIntegrationTest.java
index e931f40..8c5cf75 100644
--- a/components/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/integration/EventbridgePutRuleIntegrationTest.java
+++ b/components/camel-aws2-eventbridge/src/test/java/org/apache/camel/component/aws2/eventbridge/integration/EventbridgePutRuleIntegrationTest.java
@@ -90,8 +90,8 @@ public class EventbridgePutRuleIntegrationTest extends CamelTestSupport {
@Override
public void configure() throws Exception {
String awsEndpoint
- = "aws2-eventbridge://test?operation=putRule&eventPatternFile=file:src/test/resources/eventpattern.json";
- String target = "aws2-eventbridge://test?operation=putTargets";
+ = "aws2-eventbridge://default?operation=putRule&eventPatternFile=file:src/test/resources/eventpattern.json";
+ String target = "aws2-eventbridge://default?operation=putTargets";
from("direct:evs").to(awsEndpoint).log("${body}").to("mock:result");
from("direct:evs-targets").to(target).log("${body}").to("mock:result1");
}