This is an automated email from the ASF dual-hosted git repository.
marat pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-karavan.git
The following commit(s) were added to refs/heads/main by this push:
new 843b3fe Fix #15 (#22)
843b3fe is described below
commit 843b3fe7eaa4981f85ca45091d700ceb55c60ab3
Author: Marat Gubaidullin <marat.gubaidul...@gmail.com>
AuthorDate: Thu Oct 14 16:35:26 2021 -0400
Fix #15 (#22)
---
karavan-designer/public/components/coap+tcp.json | 1 +
karavan-designer/public/components/netty-http.json | 1348 ++++++++++++++++++++
.../public/components/pg-replication-slot.json | 449 +++++++
karavan-designer/public/components/rest-api.json | 1 +
.../public/components/rest-openapi.json | 1 +
karavan-designer/src/App.tsx | 27 +-
karavan-designer/src/designer/api/CamelApi.tsx | 2 -
karavan-designer/src/designer/api/CamelApiExt.tsx | 4 +-
karavan-designer/src/designer/api/CamelUi.tsx | 27 +-
karavan-designer/src/designer/api/CamelYaml.tsx | 6 -
karavan-designer/src/designer/api/ComponentApi.tsx | 113 +-
.../src/designer/model/ConnectionModels.tsx | 1 -
karavan-designer/src/designer/ui/DslElement.tsx | 25 +-
karavan-designer/src/designer/ui/DslInOut.tsx | 2 +-
karavan-designer/src/designer/ui/DslProperties.tsx | 9 +-
15 files changed, 1955 insertions(+), 61 deletions(-)
diff --git a/karavan-designer/public/components/coap+tcp.json
b/karavan-designer/public/components/coap+tcp.json
new file mode 100644
index 0000000..13b8839
--- /dev/null
+++ b/karavan-designer/public/components/coap+tcp.json
@@ -0,0 +1 @@
+{"component":{"kind":"component","name":"coap+tcp","title":"CoAP","description":"Send
and receive messages to/from COAP capable
devices.","deprecated":false,"firstVersion":"2.16.0","label":"iot","javaType":"org.apache.camel.coap.CoAPComponent","supportLevel":"Stable","groupId":"org.apache.camel","artifactId":"camel-coap","version":"3.11.1-SNAPSHOT","scheme":"coap+tcp","extendsScheme":"","alternativeSchemes":"coap,coaps,coap+tcp,coaps+tcp","syntax":"coap+tcp:uri","async":false,"api":false
[...]
\ No newline at end of file
diff --git a/karavan-designer/public/components/netty-http.json
b/karavan-designer/public/components/netty-http.json
new file mode 100644
index 0000000..00963b1
--- /dev/null
+++ b/karavan-designer/public/components/netty-http.json
@@ -0,0 +1,1348 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "netty-http",
+ "title": "Netty HTTP",
+ "description": "Netty HTTP server and client using the Netty 4.x.",
+ "deprecated": false,
+ "deprecationNote": "",
+ "firstVersion": "2.14.0",
+ "label": "networking,http",
+ "javaType": "org.apache.camel.component.netty.http.NettyHttpComponent",
+ "supportLevel": "Stable",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-netty-http",
+ "version": "3.11.1-SNAPSHOT",
+ "scheme": "netty-http",
+ "extendsScheme": "netty",
+ "syntax": "netty-http:protocol://host:port/path",
+ "async": true,
+ "api": false,
+ "consumerOnly": false,
+ "producerOnly": false,
+ "lenientProperties": true
+ },
+ "properties": {
+ "protocol": {
+ "kind": "path",
+ "displayName": "Protocol",
+ "group": "common",
+ "label": "",
+ "required": true,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "enum": [
+ "http",
+ "https"
+ ],
+ "deprecated": false,
+ "deprecationNote": "",
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "The protocol to use which is either http, https or proxy
- a consumer only option."
+ },
+ "host": {
+ "kind": "path",
+ "displayName": "Host",
+ "group": "common",
+ "label": "",
+ "required": true,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "deprecationNote": "",
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "The local hostname such as localhost, or 0.0.0.0 when
being a consumer. The remote HTTP server hostname when using producer."
+ },
+ "port": {
+ "kind": "path",
+ "displayName": "Port",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "The host port number"
+ },
+ "path": {
+ "kind": "path",
+ "displayName": "Path",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Resource path"
+ },
+ "bridgeEndpoint": {
+ "kind": "parameter",
+ "displayName": "Bridge Endpoint",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If the option is true, the producer will ignore the
Exchange.HTTP_URI header, and use the endpoint's URI for request. You may also
set the throwExceptionOnFailure to be false to let the producer send all the
fault response back. The consumer working in the bridge mode will skip the gzip
compression and WWW URL form encoding (by adding the
Exchange.SKIP_GZIP_ENCODING and Exchange.SKIP_WWW_FORM_URLENCODED headers to
the consumed exchange)."
+ },
+ "disconnect": {
+ "kind": "parameter",
+ "displayName": "Disconnect",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Whether or not to disconnect(close) from Netty Channel
right after use. Can be used for both consumer and producer."
+ },
+ "keepAlive": {
+ "kind": "parameter",
+ "displayName": "Keep Alive",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Setting to ensure socket is not closed due to inactivity"
+ },
+ "reuseAddress": {
+ "kind": "parameter",
+ "displayName": "Reuse Address",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Setting to facilitate socket multiplexing"
+ },
+ "reuseChannel": {
+ "kind": "parameter",
+ "displayName": "Reuse Channel",
+ "group": "common",
+ "label": "common",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "This option allows producers and consumers (in client
mode) to reuse the same Netty Channel for the lifecycle of processing the
Exchange. This is useful if you need to call a server multiple times in a Camel
route and want to use the same network connection. When using this, the channel
is not returned to the connection pool until the Exchange is done; or
disconnected if the disconnect option is set to true. The reused Channel is
stored on the Exchange as an exchang [...]
+ },
+ "sync": {
+ "kind": "parameter",
+ "displayName": "Sync",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Setting to set endpoint as one-way or request-response"
+ },
+ "tcpNoDelay": {
+ "kind": "parameter",
+ "displayName": "Tcp No Delay",
+ "group": "common",
+ "label": "",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Setting to improve TCP protocol performance"
+ },
+ "bridgeErrorHandler": {
+ "kind": "parameter",
+ "displayName": "Bridge Error Handler",
+ "group": "consumer",
+ "label": "consumer",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "description": "Allows for bridging the consumer to the Camel routing
Error Handler, which mean any exceptions occurred while the consumer is trying
to pickup incoming messages, or the likes, will now be processed as a message
and handled by the routing Error Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored."
+ },
+ "matchOnUriPrefix": {
+ "kind": "parameter",
+ "displayName": "Match On Uri Prefix",
+ "group": "consumer",
+ "label": "consumer",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Whether or not Camel should try to find a target
consumer by matching the URI prefix if no exact match is found."
+ },
+ "muteException": {
+ "kind": "parameter",
+ "displayName": "Mute Exception",
+ "group": "consumer",
+ "label": "consumer",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If enabled and an Exchange failed processing on the
consumer side the response's body won't contain the exception's stack trace."
+ },
+ "send503whenSuspended": {
+ "kind": "parameter",
+ "displayName": "Send503when Suspended",
+ "group": "consumer",
+ "label": "consumer",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Whether to send back HTTP status code 503 when the
consumer has been suspended. If the option is false then the Netty Acceptor is
unbound when the consumer is suspended, so clients cannot connect anymore."
+ },
+ "backlog": {
+ "kind": "parameter",
+ "displayName": "Backlog",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Allows to configure a backlog for netty consumer
(server). Note the backlog is just a best effort depending on the OS. Setting
this option to a value such as 200, 500 or 1000, tells the TCP stack how long
the accept queue can be If this option is not configured, then the backlog
depends on OS setting."
+ },
+ "bossCount": {
+ "kind": "parameter",
+ "displayName": "Boss Count",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 1,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "When netty works on nio mode, it uses default bossCount
parameter from Netty, which is 1. User can use this option to override the
default bossCount from Netty"
+ },
+ "bossGroup": {
+ "kind": "parameter",
+ "displayName": "Boss Group",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "io.netty.channel.EventLoopGroup",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Set the BossGroup which could be used for handling the
new connection of the server side across the NettyEndpoint"
+ },
+ "chunkedMaxContentLength": {
+ "kind": "parameter",
+ "displayName": "Chunked Max Content Length",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 1048576,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Value in bytes the max content length per chunked frame
received on the Netty HTTP server."
+ },
+ "compression": {
+ "kind": "parameter",
+ "displayName": "Compression",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Allow using gzip/deflate for compression on the Netty
HTTP server if the client supports it from the HTTP headers."
+ },
+ "disconnectOnNoReply": {
+ "kind": "parameter",
+ "displayName": "Disconnect On No Reply",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If sync is enabled then this option dictates
NettyConsumer if it should disconnect where there is no reply to send back."
+ },
+ "exceptionHandler": {
+ "kind": "parameter",
+ "displayName": "Exception Handler",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.spi.ExceptionHandler",
+ "optionalPrefix": "consumer.",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To let the consumer use a custom ExceptionHandler.
Notice if the option bridgeErrorHandler is enabled then this option is not in
use. By default the consumer will deal with exceptions, that will be logged at
WARN or ERROR level and ignored."
+ },
+ "exchangePattern": {
+ "kind": "parameter",
+ "displayName": "Exchange Pattern",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.ExchangePattern",
+ "enum": [
+ "InOnly",
+ "InOut",
+ "InOptionalOut"
+ ],
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "Sets the exchange pattern when the consumer creates an
exchange."
+ },
+ "httpMethodRestrict": {
+ "kind": "parameter",
+ "displayName": "Http Method Restrict",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To disable HTTP methods on the Netty HTTP consumer. You
can specify multiple separated by comma."
+ },
+ "logWarnOnBadRequest": {
+ "kind": "parameter",
+ "displayName": "Log Warn On Bad Request",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Whether Netty HTTP server should log a WARN if decoding
the HTTP request failed and a HTTP Status 400 (bad request) is returned."
+ },
+ "mapHeaders": {
+ "kind": "parameter",
+ "displayName": "Map Headers",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If this option is enabled, then during binding from
Netty to Camel Message then the headers will be mapped as well (eg added as
header to the Camel Message as well). You can turn off this option to disable
this. The headers can still be accessed from the
org.apache.camel.component.netty.http.NettyHttpMessage message with the method
getHttpRequest() that returns the Netty HTTP request
io.netty.handler.codec.http.HttpRequest instance."
+ },
+ "maxHeaderSize": {
+ "kind": "parameter",
+ "displayName": "Max Header Size",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 8192,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "The maximum length of all headers. If the sum of the
length of each header exceeds this value, a
io.netty.handler.codec.TooLongFrameException will be raised."
+ },
+ "nettyServerBootstrapFactory": {
+ "kind": "parameter",
+ "displayName": "Netty Server Bootstrap Factory",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType":
"org.apache.camel.component.netty.NettyServerBootstrapFactory",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "To use a custom NettyServerBootstrapFactory"
+ },
+ "nettySharedHttpServer": {
+ "kind": "parameter",
+ "displayName": "Netty Shared Http Server",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType":
"org.apache.camel.component.netty.http.NettySharedHttpServer",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To use a shared Netty HTTP server. See Netty HTTP Server
Example for more details."
+ },
+ "noReplyLogLevel": {
+ "kind": "parameter",
+ "displayName": "No Reply Log Level",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.LoggingLevel",
+ "enum": [
+ "TRACE",
+ "DEBUG",
+ "INFO",
+ "WARN",
+ "ERROR",
+ "OFF"
+ ],
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "WARN",
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If sync is enabled this option dictates NettyConsumer
which logging level to use when logging a there is no reply to send back."
+ },
+ "serverClosedChannelExceptionCaughtLogLevel": {
+ "kind": "parameter",
+ "displayName": "Server Closed Channel Exception Caught Log Level",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.LoggingLevel",
+ "enum": [
+ "TRACE",
+ "DEBUG",
+ "INFO",
+ "WARN",
+ "ERROR",
+ "OFF"
+ ],
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "DEBUG",
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If the server (NettyConsumer) catches an
java.nio.channels.ClosedChannelException then its logged using this logging
level. This is used to avoid logging the closed channel exceptions, as clients
can disconnect abruptly and then cause a flood of closed exceptions in the
Netty server."
+ },
+ "serverExceptionCaughtLogLevel": {
+ "kind": "parameter",
+ "displayName": "Server Exception Caught Log Level",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.LoggingLevel",
+ "enum": [
+ "TRACE",
+ "DEBUG",
+ "INFO",
+ "WARN",
+ "ERROR",
+ "OFF"
+ ],
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "WARN",
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If the server (NettyConsumer) catches an exception then
its logged using this logging level."
+ },
+ "serverInitializerFactory": {
+ "kind": "parameter",
+ "displayName": "Server Initializer Factory",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.component.netty.ServerInitializerFactory",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "To use a custom ServerInitializerFactory"
+ },
+ "traceEnabled": {
+ "kind": "parameter",
+ "displayName": "Trace Enabled",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "description": "Specifies whether to enable HTTP TRACE for this Netty
HTTP consumer. By default TRACE is turned off."
+ },
+ "urlDecodeHeaders": {
+ "kind": "parameter",
+ "displayName": "Url Decode Headers",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If this option is enabled, then during binding from
Netty to Camel Message then the header values will be URL decoded (eg %20 will
be a space character. Notice this option is used by the default
org.apache.camel.component.netty.http.NettyHttpBinding and therefore if you
implement a custom org.apache.camel.component.netty.http.NettyHttpBinding then
you would need to decode the headers accordingly to this option."
+ },
+ "usingExecutorService": {
+ "kind": "parameter",
+ "displayName": "Using Executor Service",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Whether to use ordered thread pool, to ensure events are
processed orderly on the same channel."
+ },
+ "connectTimeout": {
+ "kind": "parameter",
+ "displayName": "Connect Timeout",
+ "group": "producer",
+ "label": "producer",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 10000,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Time to wait for a socket connection to be available.
Value is in milliseconds."
+ },
+ "cookieHandler": {
+ "kind": "parameter",
+ "displayName": "Cookie Handler",
+ "group": "producer",
+ "label": "producer",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.http.base.cookie.CookieHandler",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "Configure a cookie handler to maintain a HTTP session"
+ },
+ "lazyStartProducer": {
+ "kind": "parameter",
+ "displayName": "Lazy Start Producer",
+ "group": "producer",
+ "label": "producer",
+ "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 [...]
+ },
+ "requestTimeout": {
+ "kind": "parameter",
+ "displayName": "Request Timeout",
+ "group": "producer",
+ "label": "producer",
+ "required": false,
+ "type": "integer",
+ "javaType": "long",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Allows to use a timeout for the Netty producer when
calling a remote server. By default no timeout is in use. The value is in milli
seconds, so eg 30000 is 30 seconds. The requestTimeout is using Netty's
ReadTimeoutHandler to trigger the timeout."
+ },
+ "throwExceptionOnFailure": {
+ "kind": "parameter",
+ "displayName": "Throw Exception On Failure",
+ "group": "producer",
+ "label": "producer",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Option to disable throwing the
HttpOperationFailedException in case of failed responses from the remote
server. This allows you to get all responses regardless of the HTTP status
code."
+ },
+ "clientInitializerFactory": {
+ "kind": "parameter",
+ "displayName": "Client Initializer Factory",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.component.netty.ClientInitializerFactory",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "To use a custom ClientInitializerFactory"
+ },
+ "lazyChannelCreation": {
+ "kind": "parameter",
+ "displayName": "Lazy Channel Creation",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Channels can be lazily created to avoid exceptions, if
the remote server is not up and running when the Camel producer is started."
+ },
+ "okStatusCodeRange": {
+ "kind": "parameter",
+ "displayName": "Ok Status Code Range",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "200-299",
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "The status codes which are considered a success
response. The values are inclusive. Multiple ranges can be defined, separated
by comma, e.g. 200-204,209,301-304. Each range must be a single number or
from-to with the dash included. The default range is 200-299"
+ },
+ "producerPoolEnabled": {
+ "kind": "parameter",
+ "displayName": "Producer Pool Enabled",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Whether producer pool is enabled or not. Important: If
you turn this off then a single shared connection is used for the producer,
also if you are doing request/reply. That means there is a potential issue with
interleaved responses if replies comes back out-of-order. Therefore you need to
have a correlation id in both the request and reply messages so you can
properly correlate the replies to the Camel callback that is responsible for
continue processing the messag [...]
+ },
+ "producerPoolMaxActive": {
+ "kind": "parameter",
+ "displayName": "Producer Pool Max Active",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": -1,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Sets the cap on the number of objects that can be
allocated by the pool (checked out to clients, or idle awaiting checkout) at a
given time. Use a negative value for no limit."
+ },
+ "producerPoolMaxIdle": {
+ "kind": "parameter",
+ "displayName": "Producer Pool Max Idle",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 100,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Sets the cap on the number of idle instances in the
pool."
+ },
+ "producerPoolMinEvictableIdle": {
+ "kind": "parameter",
+ "displayName": "Producer Pool Min Evictable Idle",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "long",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 300000,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Sets the minimum amount of time (value in millis) an
object may sit idle in the pool before it is eligible for eviction by the idle
object evictor."
+ },
+ "producerPoolMinIdle": {
+ "kind": "parameter",
+ "displayName": "Producer Pool Min Idle",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Sets the minimum number of instances allowed in the
producer pool before the evictor thread (if active) spawns new objects."
+ },
+ "useRelativePath": {
+ "kind": "parameter",
+ "displayName": "Use Relative Path",
+ "group": "producer (advanced)",
+ "label": "producer,advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Sets whether to use a relative path in HTTP requests."
+ },
+ "hostnameVerification": {
+ "kind": "parameter",
+ "displayName": "Hostname Verification",
+ "group": " security",
+ "label": "common, security",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "To enable/disable hostname verification on SSLEngine"
+ },
+ "allowSerializedHeaders": {
+ "kind": "parameter",
+ "displayName": "Allow Serialized Headers",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Only used for TCP when transferExchange is true. When
set to true, serializable objects in headers and properties will be added to
the exchange. Otherwise Camel will exclude any non-serializable objects and log
it at WARN level."
+ },
+ "channelGroup": {
+ "kind": "parameter",
+ "displayName": "Channel Group",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "io.netty.channel.group.ChannelGroup",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "To use a explicit ChannelGroup."
+ },
+ "configuration": {
+ "kind": "parameter",
+ "displayName": "Configuration",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "object",
+ "javaType":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To use a custom configured NettyHttpConfiguration for
configuring this endpoint."
+ },
+ "disableStreamCache": {
+ "kind": "parameter",
+ "displayName": "Disable Stream Cache",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Determines whether or not the raw input stream from
Netty HttpRequest#getContent() or HttpResponset#getContent() is cached or not
(Camel will read the stream into a in light-weight memory based Stream caching)
cache. By default Camel will cache the Netty input stream to support reading it
multiple times to ensure it Camel can retrieve all data from the stream.
However you can set this option to true when you for example need to access the
raw stream, such as streami [...]
+ },
+ "headerFilterStrategy": {
+ "kind": "parameter",
+ "displayName": "Header Filter Strategy",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.spi.HeaderFilterStrategy",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To use a custom
org.apache.camel.spi.HeaderFilterStrategy to filter headers."
+ },
+ "nativeTransport": {
+ "kind": "parameter",
+ "displayName": "Native Transport",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Whether to use native transport instead of NIO. Native
transport takes advantage of the host operating system and is only supported on
some platforms. You need to add the netty JAR for the host operating system you
are using. See more details at: http://netty.io/wiki/native-transports.html";
+ },
+ "nettyHttpBinding": {
+ "kind": "parameter",
+ "displayName": "Netty Http Binding",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.component.netty.http.NettyHttpBinding",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To use a custom
org.apache.camel.component.netty.http.NettyHttpBinding for binding to/from
Netty and Camel Message API."
+ },
+ "options": {
+ "kind": "parameter",
+ "displayName": "Options",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
+ "prefix": "option.",
+ "multiValue": true,
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Allows to configure additional netty options using
option. as prefix. For example option.child.keepAlive=false to set the netty
option child.keepAlive=false. See the Netty documentation for possible options
that can be used."
+ },
+ "receiveBufferSize": {
+ "kind": "parameter",
+ "displayName": "Receive Buffer Size",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 65536,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "The TCP/UDP buffer sizes to be used during inbound
communication. Size is bytes."
+ },
+ "receiveBufferSizePredictor": {
+ "kind": "parameter",
+ "displayName": "Receive Buffer Size Predictor",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Configures the buffer size predictor. See details at
Jetty documentation and this mail thread."
+ },
+ "sendBufferSize": {
+ "kind": "parameter",
+ "displayName": "Send Buffer Size",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 65536,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "The TCP/UDP buffer sizes to be used during outbound
communication. Size is bytes."
+ },
+ "synchronous": {
+ "kind": "parameter",
+ "displayName": "Synchronous",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Sets whether synchronous processing should be strictly
used"
+ },
+ "transferException": {
+ "kind": "parameter",
+ "displayName": "Transfer Exception",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "If enabled and an Exchange failed processing on the
consumer side, and if the caused Exception was send back serialized in the
response as a application/x-java-serialized-object content type. On the
producer side the exception will be deserialized and thrown as is, instead of
the HttpOperationFailedException. The caused exception is required to be
serialized. This is by default turned off. If you enable this then be aware
that Java will deserialize the incoming data [...]
+ },
+ "transferExchange": {
+ "kind": "parameter",
+ "displayName": "Transfer Exchange",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Only used for TCP. You can transfer the exchange over
the wire instead of just the body. The following fields are transferred: In
body, Out body, fault body, In headers, Out headers, fault headers, exchange
properties, exchange exception. This requires that the objects are
serializable. Camel will exclude any non-serializable objects and log it at
WARN level."
+ },
+ "workerCount": {
+ "kind": "parameter",
+ "displayName": "Worker Count",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "When netty works on nio mode, it uses default
workerCount parameter from Netty (which is cpu_core_threads x 2). User can use
this option to override the default workerCount from Netty."
+ },
+ "workerGroup": {
+ "kind": "parameter",
+ "displayName": "Worker Group",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "io.netty.channel.EventLoopGroup",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "To use a explicit EventLoopGroup as the boss thread
pool. For example to share a thread pool with multiple consumers or producers.
By default each consumer or producer has their own worker pool with 2 x cpu
count core threads."
+ },
+ "decoders": {
+ "kind": "parameter",
+ "displayName": "Decoders",
+ "group": "codec",
+ "label": "codec",
+ "required": false,
+ "type": "array",
+ "javaType": "java.util.List<io.netty.channel.ChannelHandler>",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "A list of decoders to be used. You can use a String
which have values separated by comma, and have the values be looked up in the
Registry. Just remember to prefix the value with # so Camel knows it should
lookup."
+ },
+ "encoders": {
+ "kind": "parameter",
+ "displayName": "Encoders",
+ "group": "codec",
+ "label": "codec",
+ "required": false,
+ "type": "array",
+ "javaType": "java.util.List<io.netty.channel.ChannelHandler>",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "A list of encoders to be used. You can use a String
which have values separated by comma, and have the values be looked up in the
Registry. Just remember to prefix the value with # so Camel knows it should
lookup."
+ },
+ "enabledProtocols": {
+ "kind": "parameter",
+ "displayName": "Enabled Protocols",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "TLSv1,TLSv1.1,TLSv1.2",
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Which protocols to enable when using SSL"
+ },
+ "keyStoreFile": {
+ "kind": "parameter",
+ "displayName": "Key Store File",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.io.File",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Client side certificate keystore to be used for
encryption"
+ },
+ "keyStoreFormat": {
+ "kind": "parameter",
+ "displayName": "Key Store Format",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Keystore format to be used for payload encryption.
Defaults to JKS if not set"
+ },
+ "keyStoreResource": {
+ "kind": "parameter",
+ "displayName": "Key Store Resource",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Client side certificate keystore to be used for
encryption. Is loaded by default from classpath, but you can prefix with
classpath:, file:, or http: to load the resource from different systems."
+ },
+ "needClientAuth": {
+ "kind": "parameter",
+ "displayName": "Need Client Auth",
+ "group": "security",
+ "label": "consumer,security",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Configures whether the server needs client
authentication when using SSL."
+ },
+ "passphrase": {
+ "kind": "parameter",
+ "displayName": "Passphrase",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": true,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Password setting to use in order to encrypt/decrypt
payloads sent using SSH"
+ },
+ "securityConfiguration": {
+ "kind": "parameter",
+ "displayName": "Security Configuration",
+ "group": "security",
+ "label": "consumer,security",
+ "required": false,
+ "type": "object",
+ "javaType":
"org.apache.camel.component.netty.http.NettyHttpSecurityConfiguration",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "Refers to a
org.apache.camel.component.netty.http.NettyHttpSecurityConfiguration for
configuring secure web resources."
+ },
+ "securityOptions": {
+ "kind": "parameter",
+ "displayName": "Security Options",
+ "group": "security",
+ "label": "consumer,security",
+ "required": false,
+ "type": "object",
+ "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
+ "prefix": "securityConfiguration.",
+ "multiValue": true,
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To configure NettyHttpSecurityConfiguration using
key/value pairs from the map"
+ },
+ "securityProvider": {
+ "kind": "parameter",
+ "displayName": "Security Provider",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Security provider to be used for payload encryption.
Defaults to SunX509 if not set."
+ },
+ "ssl": {
+ "kind": "parameter",
+ "displayName": "Ssl",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Setting to specify whether SSL encryption is applied to
this endpoint"
+ },
+ "sslClientCertHeaders": {
+ "kind": "parameter",
+ "displayName": "Ssl Client Cert Headers",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "When enabled and in SSL mode, then the Netty consumer
will enrich the Camel Message with headers having information about the client
certificate such as subject name, issuer name, serial number, and the valid
date range."
+ },
+ "sslContextParameters": {
+ "kind": "parameter",
+ "displayName": "Ssl Context Parameters",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.support.jsse.SSLContextParameters",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "To configure security using SSLContextParameters"
+ },
+ "sslHandler": {
+ "kind": "parameter",
+ "displayName": "Ssl Handler",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "object",
+ "javaType": "io.netty.handler.ssl.SslHandler",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Reference to a class that could be used to return an SSL
Handler"
+ },
+ "trustStoreFile": {
+ "kind": "parameter",
+ "displayName": "Trust Store File",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.io.File",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Server side certificate keystore to be used for
encryption"
+ },
+ "trustStoreResource": {
+ "kind": "parameter",
+ "displayName": "Trust Store Resource",
+ "group": "security",
+ "label": "security",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "configurationClass":
"org.apache.camel.component.netty.http.NettyHttpConfiguration",
+ "configurationField": "configuration",
+ "description": "Server side certificate keystore to be used for
encryption. Is loaded by default from classpath, but you can prefix with
classpath:, file:, or http: to load the resource from different systems."
+ }
+ }
+}
\ No newline at end of file
diff --git a/karavan-designer/public/components/pg-replication-slot.json
b/karavan-designer/public/components/pg-replication-slot.json
new file mode 100644
index 0000000..8075443
--- /dev/null
+++ b/karavan-designer/public/components/pg-replication-slot.json
@@ -0,0 +1,449 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "pg-replication-slot",
+ "title": "PostgresSQL Replication Slot",
+ "description": "Poll for PostgreSQL Write-Ahead Log (WAL) records using
Streaming Replication Slots.",
+ "deprecated": false,
+ "firstVersion": "3.0.0",
+ "label": "database,sql",
+ "javaType":
"org.apache.camel.component.pg.replication.slot.PgReplicationSlotComponent",
+ "supportLevel": "Stable",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-pg-replication-slot",
+ "version": "3.11.1-SNAPSHOT",
+ "scheme": "pg-replication-slot",
+ "extendsScheme": "",
+ "syntax": "pg-replication-slot:host:port/database/slot:outputPlugin",
+ "async": false,
+ "api": false,
+ "consumerOnly": true,
+ "producerOnly": false,
+ "lenientProperties": false
+ },
+ "properties": {
+ "slot": {
+ "kind": "path",
+ "displayName": "Slot",
+ "group": "common",
+ "label": "common",
+ "required": true,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "deprecationNote": "",
+ "autowired": false,
+ "secret": false,
+ "description": "Replication Slot name"
+ },
+ "host": {
+ "kind": "path",
+ "displayName": "Host",
+ "group": "common",
+ "label": "common",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "localhost",
+ "description": "Postgres host"
+ },
+ "port": {
+ "kind": "path",
+ "displayName": "Port",
+ "group": "common",
+ "label": "common",
+ "required": false,
+ "type": "integer",
+ "javaType": "java.lang.Integer",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "5432",
+ "description": "Postgres port"
+ },
+ "database": {
+ "kind": "path",
+ "displayName": "Database",
+ "group": "common",
+ "label": "common",
+ "required": true,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "deprecationNote": "",
+ "autowired": false,
+ "secret": false,
+ "description": "Postgres database name"
+ },
+ "outputPlugin": {
+ "kind": "path",
+ "displayName": "Output Plugin",
+ "group": "common",
+ "label": "common",
+ "required": true,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "deprecationNote": "",
+ "autowired": false,
+ "secret": false,
+ "description": "Output plugin name"
+ },
+ "password": {
+ "kind": "parameter",
+ "displayName": "Password",
+ "group": "common",
+ "label": "common",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": true,
+ "description": "Postgres password"
+ },
+ "user": {
+ "kind": "parameter",
+ "displayName": "User",
+ "group": "common",
+ "label": "common",
+ "required": false,
+ "type": "string",
+ "javaType": "java.lang.String",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "postgres",
+ "description": "Postgres user"
+ },
+ "bridgeErrorHandler": {
+ "kind": "parameter",
+ "displayName": "Bridge Error Handler",
+ "group": "consumer",
+ "label": "consumer",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "description": "Allows for bridging the consumer to the Camel routing
Error Handler, which mean any exceptions occurred while the consumer is trying
to pickup incoming messages, or the likes, will now be processed as a message
and handled by the routing Error Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored."
+ },
+ "sendEmptyMessageWhenIdle": {
+ "kind": "parameter",
+ "displayName": "Send Empty Message When Idle",
+ "group": "consumer",
+ "label": "consumer",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "description": "If the polling consumer did not poll any files, you can
enable this option to send an empty message (no body) instead."
+ },
+ "exceptionHandler": {
+ "kind": "parameter",
+ "displayName": "Exception Handler",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.spi.ExceptionHandler",
+ "optionalPrefix": "consumer.",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To let the consumer use a custom ExceptionHandler.
Notice if the option bridgeErrorHandler is enabled then this option is not in
use. By default the consumer will deal with exceptions, that will be logged at
WARN or ERROR level and ignored."
+ },
+ "exchangePattern": {
+ "kind": "parameter",
+ "displayName": "Exchange Pattern",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.ExchangePattern",
+ "enum": [
+ "InOnly",
+ "InOut",
+ "InOptionalOut"
+ ],
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "Sets the exchange pattern when the consumer creates an
exchange."
+ },
+ "pollStrategy": {
+ "kind": "parameter",
+ "displayName": "Poll Strategy",
+ "group": "consumer (advanced)",
+ "label": "consumer,advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.spi.PollingConsumerPollStrategy",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel."
+ },
+ "autoCreateSlot": {
+ "kind": "parameter",
+ "displayName": "Auto Create Slot",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "boolean",
+ "javaType": "java.lang.Boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "true",
+ "description": "Auto create slot if it does not exist"
+ },
+ "slotOptions": {
+ "kind": "parameter",
+ "displayName": "Slot Options",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "object",
+ "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
+ "prefix": "slotOptions.",
+ "multiValue": true,
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "Slot options to be passed to the output plugin."
+ },
+ "statusInterval": {
+ "kind": "parameter",
+ "displayName": "Status Interval",
+ "group": "advanced",
+ "label": "advanced",
+ "required": false,
+ "type": "integer",
+ "javaType": "java.lang.Integer",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "10",
+ "description": "Specifies the number of seconds between status packets
sent back to Postgres server."
+ },
+ "backoffErrorThreshold": {
+ "kind": "parameter",
+ "displayName": "Backoff Error Threshold",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "The number of subsequent error polls (failed due some
error) that should happen before the backoffMultipler should kick-in."
+ },
+ "backoffIdleThreshold": {
+ "kind": "parameter",
+ "displayName": "Backoff Idle Threshold",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "The number of subsequent idle polls that should happen
before the backoffMultipler should kick-in."
+ },
+ "backoffMultiplier": {
+ "kind": "parameter",
+ "displayName": "Backoff Multiplier",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "integer",
+ "javaType": "int",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To let the scheduled polling consumer backoff if there
has been a number of subsequent idles/errors in a row. The multiplier is then
the number of polls that will be skipped before the next actual attempt is
happening again. When this option is in use then backoffIdleThreshold and/or
backoffErrorThreshold must also be configured."
+ },
+ "delay": {
+ "kind": "parameter",
+ "displayName": "Delay",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "integer",
+ "javaType": "long",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 500,
+ "description": "Milliseconds before the next poll."
+ },
+ "greedy": {
+ "kind": "parameter",
+ "displayName": "Greedy",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": false,
+ "description": "If greedy is enabled, then the ScheduledPollConsumer
will run immediately again, if the previous run polled 1 or more messages."
+ },
+ "initialDelay": {
+ "kind": "parameter",
+ "displayName": "Initial Delay",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "integer",
+ "javaType": "long",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 1000,
+ "description": "Milliseconds before the first poll starts."
+ },
+ "repeatCount": {
+ "kind": "parameter",
+ "displayName": "Repeat Count",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "integer",
+ "javaType": "long",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": 0,
+ "description": "Specifies a maximum limit of number of fires. So if you
set it to 1, the scheduler will only fire once. If you set it to 5, it will
only fire five times. A value of zero or negative means fire forever."
+ },
+ "runLoggingLevel": {
+ "kind": "parameter",
+ "displayName": "Run Logging Level",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "object",
+ "javaType": "org.apache.camel.LoggingLevel",
+ "enum": [
+ "TRACE",
+ "DEBUG",
+ "INFO",
+ "WARN",
+ "ERROR",
+ "OFF"
+ ],
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "TRACE",
+ "description": "The consumer logs a start/complete log line when it
polls. This option allows you to configure the logging level for that."
+ },
+ "scheduledExecutorService": {
+ "kind": "parameter",
+ "displayName": "Scheduled Executor Service",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "object",
+ "javaType": "java.util.concurrent.ScheduledExecutorService",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "Allows for configuring a custom/shared thread pool to
use for the consumer. By default each consumer has its own single threaded
thread pool."
+ },
+ "scheduler": {
+ "kind": "parameter",
+ "displayName": "Scheduler",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "object",
+ "javaType": "java.lang.Object",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "none",
+ "description": "To use a cron scheduler from either camel-spring or
camel-quartz component. Use value spring or quartz for built in scheduler"
+ },
+ "schedulerProperties": {
+ "kind": "parameter",
+ "displayName": "Scheduler Properties",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "object",
+ "javaType": "java.util.Map<java.lang.String, java.lang.Object>",
+ "prefix": "scheduler.",
+ "multiValue": true,
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler."
+ },
+ "startScheduler": {
+ "kind": "parameter",
+ "displayName": "Start Scheduler",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "description": "Whether the scheduler should be auto started."
+ },
+ "timeUnit": {
+ "kind": "parameter",
+ "displayName": "Time Unit",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "object",
+ "javaType": "java.util.concurrent.TimeUnit",
+ "enum": [
+ "NANOSECONDS",
+ "MICROSECONDS",
+ "MILLISECONDS",
+ "SECONDS",
+ "MINUTES",
+ "HOURS",
+ "DAYS"
+ ],
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": "MILLISECONDS",
+ "description": "Time unit for initialDelay and delay options."
+ },
+ "useFixedDelay": {
+ "kind": "parameter",
+ "displayName": "Use Fixed Delay",
+ "group": "scheduler",
+ "label": "consumer,scheduler",
+ "required": false,
+ "type": "boolean",
+ "javaType": "boolean",
+ "deprecated": false,
+ "autowired": false,
+ "secret": false,
+ "defaultValue": true,
+ "description": "Controls if fixed delay or fixed rate is used. See
ScheduledExecutorService in JDK for details."
+ }
+ }
+}
\ No newline at end of file
diff --git a/karavan-designer/public/components/rest-api.json
b/karavan-designer/public/components/rest-api.json
new file mode 100644
index 0000000..3ffbaf6
--- /dev/null
+++ b/karavan-designer/public/components/rest-api.json
@@ -0,0 +1 @@
+{"component":{"kind":"component","name":"rest-api","title":"REST
API","description":"Expose OpenAPI Specification of the REST services defined
using Camel REST
DSL.","deprecated":false,"firstVersion":"2.16.0","label":"core,rest","javaType":"org.apache.camel.component.rest.RestApiComponent","supportLevel":"Stable","groupId":"org.apache.camel","artifactId":"camel-rest","version":"3.11.1-SNAPSHOT","scheme":"rest-api","extendsScheme":"","syntax":"rest-api:path/contextIdPattern","async":false
[...]
\ No newline at end of file
diff --git a/karavan-designer/public/components/rest-openapi.json
b/karavan-designer/public/components/rest-openapi.json
new file mode 100644
index 0000000..84b6a79
--- /dev/null
+++ b/karavan-designer/public/components/rest-openapi.json
@@ -0,0 +1 @@
+{"component":{"kind":"component","name":"rest-openapi","title":"REST
OpenApi","description":"Configure REST producers based on an OpenAPI
specification document delegating to a component implementing the
RestProducerFactory
interface.","deprecated":false,"firstVersion":"3.1.0","label":"openapi,rest,api","javaType":"org.apache.camel.component.rest.openapi.RestOpenApiComponent","supportLevel":"Stable","groupId":"org.apache.camel","artifactId":"camel-rest-openapi","version":"3.11.1-SNAPSHOT
[...]
\ No newline at end of file
diff --git a/karavan-designer/src/App.tsx b/karavan-designer/src/App.tsx
index e784161..5d1bb93 100644
--- a/karavan-designer/src/App.tsx
+++ b/karavan-designer/src/App.tsx
@@ -41,30 +41,39 @@ class App extends React.Component<Props, State> {
componentDidMount() {
+
["http-secured-sink.kamelet.yaml",
- "http-secured-source.kamelet.yaml",
- "http-sink.kamelet.yaml",
- "http-source.kamelet.yaml",
- "insert-field-action.kamelet.yaml",
- "insert-header-action.kamelet.yaml",
- "kafka-not-secured-sink.kamelet.yaml",
- "kafka-not-secured-source.kamelet.yaml",
- "kafka-sink.kamelet.yaml",
- "kafka-source.kamelet.yaml"].forEach(name =>
+ "http-secured-source.kamelet.yaml",
+ "http-sink.kamelet.yaml",
+ "http-source.kamelet.yaml",
+ "insert-field-action.kamelet.yaml",
+ "insert-header-action.kamelet.yaml",
+ "kafka-not-secured-sink.kamelet.yaml",
+ "kafka-not-secured-source.kamelet.yaml",
+ "kafka-sink.kamelet.yaml",
+ "kafka-source.kamelet.yaml"].forEach(name =>
fetch("kamelets/" + name)
.then((r) => r.text())
.then(value => KameletApi.saveKamelet(value)));
+
["bonita.json",
+ "netty-http.json",
"jms.json",
"sql.json",
"file.json",
"log.json",
+ "coap+tcp.json",
+ "pg-replication-slot.json",
+ "rest-api.json",
+ "rest-openapi.json",
"kubernetes-service-accounts.json",
"mvel.json"].forEach(name =>
fetch("components/" + name)
.then((r) => r.text())
.then(value => ComponentApi.saveComponent(value)));
+
+
}
save(name: string, yaml: string) {
diff --git a/karavan-designer/src/designer/api/CamelApi.tsx
b/karavan-designer/src/designer/api/CamelApi.tsx
index 90778e5..5e1c946 100644
--- a/karavan-designer/src/designer/api/CamelApi.tsx
+++ b/karavan-designer/src/designer/api/CamelApi.tsx
@@ -823,8 +823,6 @@ export class CamelApi {
switch (step.dslName){
case 'policyStep': (step as PolicyStep).policy.steps =
CamelApi.deleteStep((step as PolicyStep).policy.steps, uuidToDelete); break;
case 'choiceStep':
- console.log(step);
- console.log(uuidToDelete);
const otherwise = (step as
ChoiceStep).choice.otherwise;
if (otherwise && otherwise.uuid === uuidToDelete) {
(step as ChoiceStep).choice.otherwise =
undefined;
diff --git a/karavan-designer/src/designer/api/CamelApiExt.tsx
b/karavan-designer/src/designer/api/CamelApiExt.tsx
index dedb150..e713126 100644
--- a/karavan-designer/src/designer/api/CamelApiExt.tsx
+++ b/karavan-designer/src/designer/api/CamelApiExt.tsx
@@ -93,9 +93,10 @@ export class CamelApiExt {
let uri: any = undefined;
let expression: any = undefined;
let parameters: any = undefined;
- if (name)
+ if (name) {
CamelMetadataApi.getElementMeta(name)?.properties
.filter(p => p.name !== 'steps' && p.name !==
'inheritErrorHandler')
+ .filter(p => (name == 'to' && p.name !== 'pattern') || name
!='to')
.filter(p => !p.isObject || (p.isObject && p.name ===
'expression'))
.forEach(p => {
switch (p.name) {
@@ -112,6 +113,7 @@ export class CamelApiExt {
result.push(p)
}
})
+ }
if (uri) result.unshift(uri)
if (expression) result.unshift(expression)
if (parameters) result.push(parameters)
diff --git a/karavan-designer/src/designer/api/CamelUi.tsx
b/karavan-designer/src/designer/api/CamelUi.tsx
index c5f766b..b377e63 100644
--- a/karavan-designer/src/designer/api/CamelUi.tsx
+++ b/karavan-designer/src/designer/api/CamelUi.tsx
@@ -21,6 +21,7 @@ import {DslMetaModel} from "../model/DslMetaModel";
import {Metadata} from "./CamelMetadata";
import {ComponentApi} from "./ComponentApi";
import {ComponentProperty} from "../model/ComponentModels";
+import {CamelApiExt} from "./CamelApiExt";
const DslElements: string[] = [
"aggregate",
@@ -53,7 +54,7 @@ const DslElements: string[] = [
"validate",
"wireTap",
];
-const DslLabels = ["consumer", "producer", "routing", "transformation",
"error", "configuration"];
+// const DslLabels = ["consumer", "producer", "routing", "transformation",
"error", "configuration"];
const defaultIcon =
"data:image/svg+xml,%3Csvg viewBox='0 0 130.21 130.01'
xmlns='http://www.w3.org/2000/svg'%3E%3Cdefs%3E%3ClinearGradient id='a'
x1='333.48' x2='477' y1='702.6' y2='563.73' gradientTransform='translate(94.038
276.06) scale(.99206)' gradientUnits='userSpaceOnUse'%3E%3Cstop
stop-color='%23F69923' offset='0'/%3E%3Cstop stop-color='%23F79A23'
offset='.11'/%3E%3Cstop stop-color='%23E97826'
offset='.945'/%3E%3C/linearGradient%3E%3ClinearGradient id='b' x1='333.48'
x2='477' y1='702.6' y2='563 [...]
@@ -211,17 +212,39 @@ export class CamelUi {
static getTitle = (element: CamelElement): string => {
const uri: string = (element as any).uri;
+ const name = ComponentApi.getComponentNameFromUri(uri);
const k: Kamelet | undefined = CamelUi.getKamelet(element);
if (k) {
return k.title();
} else {
- return uri ? uri : CamelUi.capitalizeName(element.dslName);
+ return uri ? CamelUi.capitalizeName(element.dslName) + " : " +
name : CamelUi.capitalizeName(element.dslName);
}
};
+ static isShowExpressionTooltip = (element: CamelElement): boolean => {
+ const exp = CamelApiExt.getExpressionValue(element);
+ return element.hasOwnProperty("expression") && (exp !== undefined &&
exp?.trim().length > 0);
+ }
+
+ static isShowUriTooltip = (element: CamelElement): boolean => {
+ const uri: string = (element as any).uri;
+ return uri !== undefined;
+ }
+
+ static getExpressionTooltip = (element: CamelElement): string => {
+ const language = CamelApiExt.getExpressionLanguage(element) ||
'simple';
+ const value = CamelApiExt.getExpressionValue(element) || '';
+ return language.concat(": ", value);
+ }
+
+ static getUriTooltip = (element: CamelElement): string => {
+ return (element as any).uri;
+ }
+
static getKameletIcon = (uri: string | undefined): string => {
return uri ? KameletApi.findKameletByUri(uri)?.icon() || "" : "";
};
+
static getIconForName = (dslName: string): string => {
switch (dslName) {
case "filter":
diff --git a/karavan-designer/src/designer/api/CamelYaml.tsx
b/karavan-designer/src/designer/api/CamelYaml.tsx
index 3e3e8b3..cb2097e 100644
--- a/karavan-designer/src/designer/api/CamelYaml.tsx
+++ b/karavan-designer/src/designer/api/CamelYaml.tsx
@@ -18,12 +18,6 @@ import * as yaml from 'js-yaml';
import {
Integration,
CamelElement,
- ToStep,
- Otherwise,
- Expression,
- WhenStep,
- ChoiceStep,
- FilterStep, FromStep, MulticastStep,
} from "../model/CamelModel";
import {CamelApi} from "./CamelApi";
diff --git a/karavan-designer/src/designer/api/ComponentApi.tsx
b/karavan-designer/src/designer/api/ComponentApi.tsx
index 3f59ffe..a003650 100644
--- a/karavan-designer/src/designer/api/ComponentApi.tsx
+++ b/karavan-designer/src/designer/api/ComponentApi.tsx
@@ -15,7 +15,6 @@
* limitations under the License.
*/
import {Component, ComponentProperty} from "../model/ComponentModels";
-import {Kamelet, Property} from "../model/KameletModels";
export const Components: Component[] = [];
@@ -54,31 +53,103 @@ export const ComponentApi = {
return uri.split(":")[0];
},
- getPathParameterValue: (uri: string, pathParameter: string): string |
undefined => {
+ getUriParts: (uri: string): Map<string, string> => {
+ const result: Map<string, string> = new Map<string, string>();
const name = ComponentApi.getComponentNameFromUri(uri);
- if (name){
+ if (name) {
const component = ComponentApi.findByName(name);
const syntax = component?.component.syntax;
- const index = syntax?.split(":").findIndex(s => s ===
pathParameter);
- const uriParts = uri.split(":");
- return index && uriParts.length > index ? uriParts[index] :
undefined;
+ const syntaxParts = ComponentApi.parseSyntax(syntax+'');
+ const syntaxSeparators =
ComponentApi.getSyntaxSeparators(syntax+'');
+ let newUri = uri === name ? name+syntaxSeparators.join('') : uri;
+ result.set(name, name);
+ syntaxParts.filter((x,i) => i > 0).forEach((part, index) => {
+ if (index < syntaxParts.length -1) {
+ const startSeparator = syntaxSeparators[index];
+ const endSeparator = syntaxSeparators[index + 1];
+ const start = newUri.indexOf(startSeparator) +
startSeparator.length;
+ const end = endSeparator ? newUri.indexOf(endSeparator,
start) : newUri.length;
+ const val = newUri.substr(start, end-start);
+ result.set(part, val);
+ newUri = newUri.substr(end);
+ }
+ })
}
- return undefined;
+ return result;
},
- buildComponentUri: (uri: string, pathParameter: string,
pathParameterValue: string): string | undefined => {
+ parseSyntax: (syntax: string): string[] => {
+ const separators: string[] = ['://', '//', ':', '/', '#']
+ let simplifiedSyntax = ''+ syntax;
+ separators.forEach(s => {
+ simplifiedSyntax = simplifiedSyntax?.replaceAll(s, ":");
+ });
+ return simplifiedSyntax.split(":");
+ },
+
+ getSyntaxSeparators: (syntax: string): string[] => {
+ const result: string[] = [];
+ const parts: string[] = ComponentApi.parseSyntax(syntax);
+ let str = '';
+ parts.forEach((part, index) => {
+ if (index < parts.length -1){
+ const start = syntax.indexOf(part, str.length) +
part.length;
+ const end = syntax.indexOf(parts[index + 1], start);
+ const separator = syntax.substr(start, end - start);
+ result.push(separator);
+ str = str + part + separator;
+ }
+ })
+ return result;
+ },
+
+ parseUri: (uri?: string): string[] => {
+ const separators: string[] = ['://', '//', ':', '/', '#']
+ let simplifiedUri = ''+ uri;
+ separators.forEach(s => {
+ simplifiedUri = simplifiedUri?.replaceAll(s, ":");
+ });
+ return simplifiedUri.split(":");
+ },
+
+ getUriSeparators: (uri: string): string[] => {
+ const result: string[] = [];
const name = ComponentApi.getComponentNameFromUri(uri);
- if (name){
+ if (name) {
const component = ComponentApi.findByName(name);
- const syntax = component?.component.syntax;
- const uriParts = uri.split(":");
- const result:string[] = [];
- syntax?.split(":").forEach((value, index, array) => {
- if (value === pathParameter) result.push(pathParameterValue)
- else if (uriParts.length > index) result.push(uriParts[index])
- else result.push("")
+ const syntax = '' + component?.component.syntax;
+ const parts: string[] =
Array.from(ComponentApi.getUriParts(uri).keys());
+ let str = '';
+ parts.forEach((part, index) => {
+ if (index < parts.length -1){
+ const start = syntax.indexOf(part, str.length) +
part.length;
+ const end = syntax.indexOf(parts[index + 1], start);
+ const separator = syntax.substr(start, end - start);
+ result.push(separator);
+ str = str + part + separator;
+ }
+ })
+ }
+ return result;
+ },
+
+ getPathParameterValue: (uri: string, pathParameter: string): string |
undefined => {
+ return ComponentApi.getUriParts(uri).get(pathParameter);
+ },
+
+ buildComponentUri: (uri: string, pathParameter: string,
pathParameterValue: string): string | undefined => {
+ const name = ComponentApi.getComponentNameFromUri(uri);
+ if (name) {
+ const map = ComponentApi.getUriParts(uri);
+ map.set(pathParameter, pathParameterValue);
+ const separators = ComponentApi.getUriSeparators(uri);
+ const result: string[] = [];
+ Array.from(map.keys()).forEach((key, index) => {
+ const val = map.get(key);
+ result.push(val ? val : '');
+ result.push(separators[index]);
});
- return result.join(":");
+ return result.join('');
}
return uri;
},
@@ -109,9 +180,11 @@ export const ComponentApi = {
} finally {
const result: ComponentProperty[] = [];
if (!advanced) {
- result.push(...properties.filter(p => p.label.length === 0));
- result.push(...properties.filter(p => p.label.startsWith(type)
&& !p.label.includes("advanced")));
- result.push(...properties.filter(p => p.label ===
"formatting"));
+ result.push(...properties.filter(p => p.kind === 'path'));
+ result.push(...properties.filter(p => p.kind !== 'path' &&
p.required));
+ result.push(...properties.filter(p => p.label.length === 0 &&
p.kind !== 'path' && !p.required));
+ result.push(...properties.filter(p => p.label.startsWith(type)
&& !p.label.includes("advanced") && !p.required));
+ result.push(...properties.filter(p => p.label === "formatting"
&& !p.required));
} else {
result.push(...properties.filter(p => p.label.startsWith(type)
&& p.label.includes("advanced")));
result.push(...properties.filter(p => p.label === "advanced"));
diff --git a/karavan-designer/src/designer/model/ConnectionModels.tsx
b/karavan-designer/src/designer/model/ConnectionModels.tsx
index 8c141e1..4dc0d3d 100644
--- a/karavan-designer/src/designer/model/ConnectionModels.tsx
+++ b/karavan-designer/src/designer/model/ConnectionModels.tsx
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-import {CamelUi} from "../api/CamelUi";
export class InOut {
type: 'in' | 'out' = 'in';
diff --git a/karavan-designer/src/designer/ui/DslElement.tsx
b/karavan-designer/src/designer/ui/DslElement.tsx
index 263574f..28aba5e 100644
--- a/karavan-designer/src/designer/ui/DslElement.tsx
+++ b/karavan-designer/src/designer/ui/DslElement.tsx
@@ -104,17 +104,6 @@ export class DslElement extends React.Component<Props,
State> {
return this.state.step.dslName.startsWith("from");
}
- isShowTooltip = (): boolean => {
- const exp = CamelApiExt.getExpressionValue(this.state.element);
- return this.state.element.hasOwnProperty("expression") && (exp !==
undefined && exp?.trim().length > 0);
- }
-
- getExpressionTooltip = (): string => {
- const language = CamelApiExt.getExpressionLanguage(this.state.element)
|| 'simple';
- const value = CamelApiExt.getExpressionValue(this.state.element) || '';
- return language.concat(": ", value);
- }
-
getArrow = () => {
return (
<svg className={"arrow-down"} viewBox="0 0 483.284 483.284"
width="16" height="16"
@@ -149,15 +138,21 @@ export class DslElement extends React.Component<Props,
State> {
);
}
- getHeaderWithTooltip = () => {
+ getHeaderWithTooltip = (tooltip: string | undefined) => {
return (
- <Tooltip position={"auto"} disabled={this.isShowTooltip()}
- content={<div>{this.getExpressionTooltip()}</div>}>
+ <Tooltip position={"auto"}
disabled={CamelUi.isShowExpressionTooltip(this.state.element)}
+ content={<div>{tooltip}</div>}>
{this.getHeader()}
</Tooltip>
);
}
+ getHeaderTooltip = (): string | undefined => {
+ if (CamelUi.isShowExpressionTooltip(this.state.element)) return
CamelUi.getExpressionTooltip(this.state.element);
+ if (CamelUi.isShowUriTooltip(this.state.element)) return
CamelUi.getUriTooltip(this.state.element);
+ return undefined;
+ }
+
render() {
return (
<div className={
@@ -173,7 +168,7 @@ export class DslElement extends React.Component<Props,
State> {
onClick={event => this.selectElement(event)}
>
- {this.isShowTooltip() ? this.getHeaderWithTooltip() :
this.getHeader()}
+ {this.getHeaderWithTooltip(this.getHeaderTooltip())}
{this.state.element.hasSteps() && !this.horizontal() &&
this.getArrow()}
<div className={this.state.element.dslName}>
{this.state.element.hasSteps() &&
diff --git a/karavan-designer/src/designer/ui/DslInOut.tsx
b/karavan-designer/src/designer/ui/DslInOut.tsx
index 7f79f9a..4ec415f 100644
--- a/karavan-designer/src/designer/ui/DslInOut.tsx
+++ b/karavan-designer/src/designer/ui/DslInOut.tsx
@@ -18,7 +18,7 @@ import React from 'react';
import '../karavan.css';
import {InOut} from "../model/ConnectionModels";
import {Subscription} from "rxjs";
-import {DslPosition, EventBus} from "../api/EventBus";
+import {EventBus} from "../api/EventBus";
import {Text} from "@patternfly/react-core";
interface Props {
diff --git a/karavan-designer/src/designer/ui/DslProperties.tsx
b/karavan-designer/src/designer/ui/DslProperties.tsx
index bbb037b..fdab21c 100644
--- a/karavan-designer/src/designer/ui/DslProperties.tsx
+++ b/karavan-designer/src/designer/ui/DslProperties.tsx
@@ -25,7 +25,7 @@ import {
Switch,
NumberInput,
Button,
- TextVariants, Select, SelectVariant, SelectDirection, SelectOption,
TextArea, ExpandableSection, PageSection
+ TextVariants, Select, SelectVariant, SelectDirection, SelectOption,
TextArea, ExpandableSection
} from '@patternfly/react-core';
import '../karavan.css';
import "@patternfly/patternfly/patternfly.css";
@@ -242,6 +242,7 @@ export class DslProperties extends React.Component<Props,
State> {
key={id}
label={property.displayName}
fieldId={id}
+ isRequired={property.kind === 'path' || property.required}
labelIcon={
<Popover
position={"left"}
@@ -287,10 +288,10 @@ export class DslProperties extends React.Component<Props,
State> {
<NumberInput
className="number-property"
id={id} name={id}
- value={typeof value === 'number' ? value : undefined}
+ value={value !== undefined ? (typeof value ===
'number' ? value : Number(value)) : property.defaultValue}
inputName={id}
- onMinus={() => this.parametersChanged(property.name,
typeof value === 'number' ? value - 1 : -1, property.kind === 'path')}
- onPlus={() => this.parametersChanged(property.name,
typeof value === 'number' ? value + 1 : 1, property.kind === 'path')}
+ onMinus={() => this.parametersChanged(property.name,
typeof value === 'number' ? value - 1 : Number(value) -1, property.kind ===
'path')}
+ onPlus={() => this.parametersChanged(property.name,
typeof value === 'number' ? value + 1 : Number(value) + 1, property.kind ===
'path')}
onChange={(e: any) =>
this.parametersChanged(property.name, Number(e.target.value), property.kind ===
'path')}/>
<Button
className="clear-button"
