You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
"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.",
"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.",
Copy file name to clipboardExpand all lines: camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-sink.json
+14Lines changed: 14 additions & 0 deletions
Original file line number
Diff line number
Diff line change
@@ -220,6 +220,13 @@
220
220
"priority": "MEDIUM",
221
221
"required": "false"
222
222
},
223
+
"camel.sink.endpoint.shutdownTimeout": {
224
+
"name": "camel.sink.endpoint.shutdownTimeout",
225
+
"description": "Shutdown await timeout in milliseconds",
226
+
"defaultValue": "100",
227
+
"priority": "MEDIUM",
228
+
"required": "false"
229
+
},
223
230
"camel.sink.endpoint.synchronous": {
224
231
"name": "camel.sink.endpoint.synchronous",
225
232
"description": "Sets whether synchronous processing should be strictly used",
@@ -600,6 +607,13 @@
600
607
"priority": "MEDIUM",
601
608
"required": "false"
602
609
},
610
+
"camel.component.netty.shutdownTimeout": {
611
+
"name": "camel.component.netty.shutdownTimeout",
612
+
"description": "Shutdown await timeout in milliseconds",
613
+
"defaultValue": "100",
614
+
"priority": "MEDIUM",
615
+
"required": "false"
616
+
},
603
617
"camel.component.netty.transferExchange": {
604
618
"name": "camel.component.netty.transferExchange",
605
619
"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.",
Copy file name to clipboardExpand all lines: camel-kafka-connector-catalog/src/generated/resources/connectors/camel-netty-source.json
+14Lines changed: 14 additions & 0 deletions
Original file line number
Diff line number
Diff line change
@@ -266,6 +266,13 @@
266
266
"priority": "MEDIUM",
267
267
"required": "false"
268
268
},
269
+
"camel.source.endpoint.shutdownTimeout": {
270
+
"name": "camel.source.endpoint.shutdownTimeout",
271
+
"description": "Shutdown await timeout in milliseconds",
272
+
"defaultValue": "100",
273
+
"priority": "MEDIUM",
274
+
"required": "false"
275
+
},
269
276
"camel.source.endpoint.synchronous": {
270
277
"name": "camel.source.endpoint.synchronous",
271
278
"description": "Sets whether synchronous processing should be strictly used",
@@ -695,6 +702,13 @@
695
702
"priority": "MEDIUM",
696
703
"required": "false"
697
704
},
705
+
"camel.component.netty.shutdownTimeout": {
706
+
"name": "camel.component.netty.shutdownTimeout",
707
+
"description": "Shutdown await timeout in milliseconds",
708
+
"defaultValue": "100",
709
+
"priority": "MEDIUM",
710
+
"required": "false"
711
+
},
698
712
"camel.component.netty.transferExchange": {
699
713
"name": "camel.component.netty.transferExchange",
700
714
"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.",
"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.",
"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.",
Copy file name to clipboardExpand all lines: connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSinkConnectorConfig.java
+8Lines changed: 8 additions & 0 deletions
Original file line number
Diff line number
Diff line change
@@ -140,6 +140,9 @@ public class CamelNettyhttpSinkConnectorConfig
publicstaticfinalStringCAMEL_SINK_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes to be used during outbound communication. Size is bytes.";
publicstaticfinalStringCAMEL_SINK_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes to be used during outbound communication. Size is bytes.";
publicstaticfinalStringCAMEL_SINK_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DOC = "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.";
Copy file name to clipboardExpand all lines: connectors/camel-netty-http-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/nettyhttp/CamelNettyhttpSourceConnectorConfig.java
+8Lines changed: 8 additions & 0 deletions
Original file line number
Diff line number
Diff line change
@@ -173,6 +173,9 @@ public class CamelNettyhttpSourceConnectorConfig
publicstaticfinalStringCAMEL_SOURCE_NETTYHTTP_ENDPOINT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes to be used during outbound communication. Size is bytes.";
publicstaticfinalStringCAMEL_SOURCE_NETTYHTTP_COMPONENT_SEND_BUFFER_SIZE_DOC = "The TCP/UDP buffer sizes to be used during outbound communication. Size is bytes.";
publicstaticfinalStringCAMEL_SOURCE_NETTYHTTP_COMPONENT_TRANSFER_EXCHANGE_DOC = "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.";
0 commit comments