Skip to content

CAMEL-24373: camel-alibaba: Enhance EventBridge validation, multi-bus DSL, and documentation #26010

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
davsclaus merged 6 commits into from
Sep 2, 2026
Merged

CAMEL-24373: camel-alibaba: Enhance EventBridge validation, multi-bus DSL, and documentation #26010

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
965714d
CAMEL-24373: camel-alibaba: Enhance EventBridge validation, multi-bus
arunsrajan Aug 28, 2026
43999d8
Regen
Croway Sep 1, 2026
32bd38e
CAMEL-24373: camel-alibaba-eventbridge: Address PR #26010 review feed…
arunsrajan Sep 2, 2026
e8bcb77
CAMEL-24373: docs(alibaba-eventbridge): sync catalog documentation mi…
arunsrajan Sep 2, 2026
967896a
Merge branch 'main' into feature/CAMEL-24373-alibaba-event-bridge-cache
arunsrajan Sep 2, 2026
5a12e3c
CAMEL-24373: camel-alibaba: Address PR #26010 review feedback from @g…
arunsrajan Sep 2, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 22 additions & 12 deletions ...alog/src/generated/resources/org/apache/camel/catalog/components/alibaba-eventbridge.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,20 +34,30 @@
"CamelAlibabaEventBridgeEventSource": { "index": 1, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Event source override", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#EVENT_SOURCE" },
"CamelAlibabaEventBridgeEventType": { "index": 2, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Event type override", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#EVENT_TYPE" },
"CamelAlibabaEventBridgeEventSubject": { "index": 3, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Event subject override", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#EVENT_SUBJECT" },
"CamelAlibabaEventBridgeRequestId": { "index": 4, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Alibaba Cloud request id", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#REQUEST_ID" }
"CamelAlibabaEventBridgeValidateEventSource": { "index": 4, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Validate event source against Alibaba Cloud EventBridge", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#VALIDATE_EVENT_SOURCE" },
"CamelAlibabaEventBridgeValidateEventType": { "index": 5, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Validate event type against Alibaba Cloud EventBridge rule filter patterns", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#VALIDATE_EVENT_TYPE" },
"CamelAlibabaEventBridgeValidateEventSpec": { "index": 6, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Validate CloudEvents 1.0 specification constraints on map fields", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#VALIDATE_EVENT_SPEC" },
"CamelAlibabaEventBridgeAllowedEventSources": { "index": 7, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Object", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Allowed event sources and source-scoped event types per event bus (DSL string, JSON, Map, or List)", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#ALLOWED_EVENT_SOURCES" },
"CamelAlibabaEventBridgeEventSourceCacheTtl": { "index": 8, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "TTL in milliseconds for cached bus event sources and types", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#EVENT_SOURCE_CACHE_TTL" },
"CamelAlibabaEventBridgeRequestId": { "index": 9, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Alibaba Cloud request id", "constantName": "org.apache.camel.component.alibaba.eventbridge.constants.AlibabaEventBridgeHeaders#REQUEST_ID" }
},
"properties": {
"operation": { "index": 0, "kind": "path", "displayName": "Operation", "group": "producer", "label": "producer", "required": true, "type": "enum", "javaType": "java.lang.String", "enum": [ "putEvents" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Operation to perform" },
"endpoint": { "index": 1, "kind": "parameter", "displayName": "Endpoint", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "EventBridge endpoint URL. Carries higher precedence than region based client initialization" },
"eventBusName": { "index": 2, "kind": "parameter", "displayName": "Event Bus Name", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event bus name" },
"eventSource": { "index": 3, "kind": "parameter", "displayName": "Event Source", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event source" },
"eventSubject": { "index": 4, "kind": "parameter", "displayName": "Event Subject", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event subject" },
"eventType": { "index": 5, "kind": "parameter", "displayName": "Event Type", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event type" },
"region": { "index": 6, "kind": "parameter", "displayName": "Region", "group": "producer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Alibaba Cloud region" },
"lazyStartProducer": { "index": 7, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing." },
"eventBridgeClient": { "index": 8, "kind": "parameter", "displayName": "EventBridge Client", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "com.aliyun.eventbridge.EventBridgeClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "description": "Autowire an existing EventBridge client instance" },
"accessKey": { "index": 9, "kind": "parameter", "displayName": "Access Key", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "security": "secret", "description": "Access key for the cloud user" },
"secretKey": { "index": 10, "kind": "parameter", "displayName": "Secret Key", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "security": "secret", "description": "Secret key for the cloud user" },
"serviceKeys": { "index": 11, "kind": "parameter", "displayName": "Service Keys", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "org.apache.camel.component.alibaba.common.models.ServiceKeys", "deprecated": false, "autowired": false, "secret": true, "security": "secret", "description": "Configuration object for cloud service authentication" }
"allowedEventSources": { "index": 1, "kind": "parameter", "displayName": "Allowed Event Sources", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Allowed event sources and source-scoped event types per event bus. Supports multi-bus DSL (bussrc - type1,type2), single-bus shorthand (src - type1,type2), JSON string, or Map\/List objects." },
"endpoint": { "index": 2, "kind": "parameter", "displayName": "Endpoint", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "EventBridge endpoint URL. Carries higher precedence than region based client initialization" },
"eventBusName": { "index": 3, "kind": "parameter", "displayName": "Event Bus Name", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event bus name" },
"eventSource": { "index": 4, "kind": "parameter", "displayName": "Event Source", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event source" },
"eventSubject": { "index": 5, "kind": "parameter", "displayName": "Event Subject", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event subject" },
"eventType": { "index": 6, "kind": "parameter", "displayName": "Event Type", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Default event type" },
"region": { "index": 7, "kind": "parameter", "displayName": "Region", "group": "producer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Alibaba Cloud region" },
"validateEventSource": { "index": 8, "kind": "parameter", "displayName": "Validate Event Source", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "When true, verifies that the target event bus exists in Alibaba Cloud EventBridge using listEventBuses before publishing. Also validates the CloudEvent source URI against the allowedEventSources whitelist when that option is set." },
"validateEventSpec": { "index": 9, "kind": "parameter", "displayName": "Validate Event Spec", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Validate CloudEvents 1.0 specification constraints on map fields" },
"validateEventType": { "index": 10, "kind": "parameter", "displayName": "Validate Event Type", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "When true, verifies that the CloudEvent event type is valid for the event source on the target event bus against Alibaba Cloud rule filter patterns before publishing." },
"eventSourceCacheTtl": { "index": 11, "kind": "parameter", "displayName": "Event Source Cache TTL", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 300000, "description": "TTL in milliseconds for caching event bus existence lookups per bus name. Applies only when validateEventSource is true." },
"lazyStartProducer": { "index": 12, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing." },
"eventBridgeClient": { "index": 13, "kind": "parameter", "displayName": "EventBridge Client", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "com.aliyun.eventbridge.EventBridgeClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "description": "Autowire an existing EventBridge client instance" },
"accessKey": { "index": 14, "kind": "parameter", "displayName": "Access Key", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "security": "secret", "description": "Access key for the cloud user" },
"secretKey": { "index": 15, "kind": "parameter", "displayName": "Secret Key", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "security": "secret", "description": "Secret key for the cloud user" },
"serviceKeys": { "index": 16, "kind": "parameter", "displayName": "Service Keys", "group": "security", "label": "security", "required": false, "type": "object", "javaType": "org.apache.camel.component.alibaba.common.models.ServiceKeys", "deprecated": false, "autowired": false, "secret": true, "security": "secret", "description": "Configuration object for cloud service authentication" }
}
}
Loading