CAMEL-24961: Catalog body types for mina, mllp, grpc, thrift, avro, cometd, quickfix, jgroups and five more network components

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/asterisk.json

@@ -34,6 +34,11 @@
     "CamelAsteriskContext": { "index": 2, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the context that contains the extension to query in case of an ExtensionStateAction.", "constantName": "org.apache.camel.component.asterisk.AsteriskConstants#CONTEXT" },
     "CamelAsteriskAction": { "index": 3, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "org.apache.camel.component.asterisk.AsteriskAction", "enum": [ "QUEUE_STATUS", "SIP_PEERS", "EXTENSION_STATE" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The Asterisk action to do.", "constantName": "org.apache.camel.component.asterisk.AsteriskConstants#ACTION" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "pojo" ], "javaType": "org.asteriskjava.manager.event.ManagerEvent", "description": "The AMI event: a subclass of ManagerEvent such as NewChannelEvent or HangupEvent, with its simple class name in the CamelAsteriskEventName header. The ConnectEvent of the login comes first" },
+    "producerIn": { "carriers": [ "any" ], "description": "The body is not read: the action comes from the action option or the CamelAsteriskAction header, and the extension and context of EXTENSION_STATE from the CamelAsteriskExtension and CamelAsteriskContext headers" },
+    "producerOut": { "carriers": [ "pojo" ], "javaType": "org.asteriskjava.manager.response.ManagerResponse", "description": "The ManagerResponse of the action, such as an ExtensionStateResponse; a ManagerError when Asterisk answers with an error. QUEUE_STATUS and SIP_PEERS give only the first response, not the events of the list" }
+  },
   "properties": {
     "name": { "index": 0, "kind": "path", "displayName": "Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Name of component" },
     "hostname": { "index": 1, "kind": "parameter", "displayName": "Hostname", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The hostname of the asterisk server" },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/avro.json

@@ -39,6 +39,12 @@
   "headers": {
     "CamelAvroMessageName": { "index": 0, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the message to send. In consumer overrides message name from URI (if any)", "constantName": "org.apache.camel.component.avro.AvroConstants#AVRO_MESSAGE_NAME" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "list" ], "javaType": "java.lang.Object[]", "byOption": [ { "option": "singleParameter", "value": "true", "carriers": [ "unknown" ] } ], "description": "An Object array of the parameters of the called message, in the order of the protocol, with the message name in the CamelAvroMessageName header. With singleParameter the one parameter itself, such as a record" },
+    "consumerReply": { "carriers": [ "any" ], "description": "The response of the message, of its type in the protocol, such as the record class; it is not converted, so text or a Map fails for a record. Ignored for a message with a null response" },
+    "producerIn": { "carriers": [ "list", "pojo", "text", "value" ], "description": "An Object array of the parameters of the message, in the order of the protocol, or the one parameter itself, such as a record. A java.util.List is not unpacked and a Map is not a record: build the parameter types of the protocol. The message name comes from the CamelAvroMessageName header, or else from the endpoint" },
+    "producerOut": { "carriers": [ "unknown" ], "description": "The response of the message, of its type in the protocol, such as the record class; no body for a message with a null response" }
+  },
   "properties": {
     "transport": { "index": 0, "kind": "path", "displayName": "Transport", "group": "common", "label": "", "required": true, "type": "enum", "javaType": "org.apache.camel.component.avro.AvroTransport", "enum": [ "http", "netty" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.avro.AvroConfiguration", "configurationField": "configuration", "description": "Transport to use, can be either http or netty" },
     "port": { "index": 1, "kind": "path", "displayName": "Port", "group": "common", "label": "", "required": true, "type": "integer", "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.avro.AvroConfiguration", "configurationField": "configuration", "description": "Port number to use" },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/cometd.json

@@ -40,6 +40,12 @@
     "CometdClientId": { "index": 0, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The clientId of the session", "constantName": "org.apache.camel.component.cometd.CometdBinding#COMETD_CLIENT_ID_HEADER_NAME" },
     "subscription": { "index": 1, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The subscription", "constantName": "org.apache.camel.component.cometd.CometdBinding#COMETD_SUBSCRIPTION_HEADER_NAME" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "text", "value", "map", "list", "null" ], "description": "The data of the Bayeux message, parsed from JSON: a String, a number or a boolean, a Map for an object, a List for an array, or null. From a cometd producer in the same JVM the body that producer sent, as is" },
+    "consumerReply": { "carriers": [ "text", "value", "map", "list" ], "description": "Only when the exchange is InOut (exchangePattern=InOut, or set in the route): the body the route ends with is sent back to the client that published, as JSON. Bytes become an array of numbers; a stream, a file or another object is sent as the text of its toString" },
+    "producerIn": { "carriers": [ "text", "value", "map", "list" ], "description": "The data published to the channel, sent as JSON to the subscribed clients: text, a number or a boolean, a Map or a List. Bytes become an array of numbers; a stream, a file or another object is sent as the text of its toString: convert it first. The headers go in the ext field of the message" },
+    "producerOut": { "carriers": [ "unchanged" ] }
+  },
   "properties": {
     "host": { "index": 0, "kind": "path", "displayName": "Host", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Hostname" },
     "port": { "index": 1, "kind": "path", "displayName": "Port", "group": "common", "label": "", "required": true, "type": "integer", "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Host port number" },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/cometds.json

@@ -40,6 +40,12 @@
     "CometdClientId": { "index": 0, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The clientId of the session", "constantName": "org.apache.camel.component.cometd.CometdBinding#COMETD_CLIENT_ID_HEADER_NAME" },
     "subscription": { "index": 1, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The subscription", "constantName": "org.apache.camel.component.cometd.CometdBinding#COMETD_SUBSCRIPTION_HEADER_NAME" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "text", "value", "map", "list", "null" ], "description": "The data of the Bayeux message, parsed from JSON: a String, a number or a boolean, a Map for an object, a List for an array, or null. From a cometd producer in the same JVM the body that producer sent, as is" },
+    "consumerReply": { "carriers": [ "text", "value", "map", "list" ], "description": "Only when the exchange is InOut (exchangePattern=InOut, or set in the route): the body the route ends with is sent back to the client that published, as JSON. Bytes become an array of numbers; a stream, a file or another object is sent as the text of its toString" },
+    "producerIn": { "carriers": [ "text", "value", "map", "list" ], "description": "The data published to the channel, sent as JSON to the subscribed clients: text, a number or a boolean, a Map or a List. Bytes become an array of numbers; a stream, a file or another object is sent as the text of its toString: convert it first. The headers go in the ext field of the message" },
+    "producerOut": { "carriers": [ "unchanged" ] }
+  },
   "properties": {
     "host": { "index": 0, "kind": "path", "displayName": "Host", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Hostname" },
     "port": { "index": 1, "kind": "path", "displayName": "Port", "group": "common", "label": "", "required": true, "type": "integer", "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Host port number" },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/grpc.json

@@ -34,6 +34,12 @@
     "CamelGrpcUserAgent": { "index": 1, "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If provided, the given agent will prepend the gRPC library's user agent information", "constantName": "org.apache.camel.component.grpc.GrpcConstants#GRPC_USER_AGENT_HEADER" },
     "CamelGrpcEventType": { "index": 2, "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Received event type from the sent request. Possible values: onNext onCompleted onError", "constantName": "org.apache.camel.component.grpc.GrpcConstants#GRPC_EVENT_TYPE_HEADER" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "pojo" ], "byOption": [ { "option": "consumerStrategy", "value": "AGGREGATION", "carriers": [ "pojo", "list" ] }, { "option": "forwardOnCompleted", "value": "true", "carriers": [ "pojo", "null" ] } ], "description": "The protobuf request message of the called method, with the method name in the CamelGrpcMethodName header. A streaming request gives one exchange per message, or with the AGGREGATION strategy a List of all its messages. forwardOnCompleted sends no body at the end of the stream, forwardOnError the Throwable" },
+    "consumerReply": { "carriers": [ "pojo", "list", "null" ], "dependsOn": [ "routeControlledStreamObserver" ], "description": "The protobuf response message, or a List of them for a streaming response; no body sends an empty message. Text, bytes or a Map fail: build the message of the method. With routeControlledStreamObserver the route replies through a producer with toRouteControlledStreamObserver" },
+    "producerIn": { "carriers": [ "pojo", "list" ], "description": "The protobuf request message of the method, or a List of them for a streaming request. Text, bytes or a Map fail with an argument type mismatch: build the message first" },
+    "producerOut": { "carriers": [ "list" ], "byOption": [ { "option": "synchronous", "value": "true", "carriers": [ "pojo", "list" ] }, { "option": "producerStrategy", "value": "STREAMING", "carriers": [ "unchanged" ] }, { "option": "toRouteControlledStreamObserver", "value": "true", "carriers": [ "unchanged" ] } ], "description": "A List of the protobuf response messages. With synchronous=true the response message itself, or a List of them for a streaming response. With the STREAMING strategy the body is unchanged and each response goes to the streamRepliesTo endpoint" }
+  },
   "properties": {
     "host": { "index": 0, "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.grpc.GrpcConfiguration", "configurationField": "configuration", "description": "The gRPC server host name. This is localhost or 0.0.0.0 when being a consumer or remote server host name when using producer." },
     "port": { "index": 1, "kind": "path", "displayName": "Port", "group": "common", "label": "", "required": true, "type": "integer", "javaType": "int", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.grpc.GrpcConfiguration", "configurationField": "configuration", "description": "The gRPC local or remote server port" },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jgroups-raft.json

@@ -46,6 +46,11 @@
     "CamelJGroupsRaftSetTimeout": { "index": 10, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Timeout to be used in set() operation.", "constantName": "org.apache.camel.component.jgroups.raft.JGroupsRaftConstants#HEADER_JGROUPSRAFT_SET_TIMEOUT" },
     "CamelJGroupsRaftSetTimeUnit": { "index": 11, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "java.util.concurrent.TimeUnit", "enum": [ "NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Timeunit to be used in set() operation.", "constantName": "org.apache.camel.component.jgroups.raft.JGroupsRaftConstants#HEADER_JGROUPSRAFT_SET_TIMEUNIT" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "null" ], "description": "No body: an event for each change of the role of this member (only with enableRoleChangeEvents), with LEADER or FOLLOWER in the CamelJGroupsRaftEventType header and the state of the raft in the other headers" },
+    "producerIn": { "carriers": [ "bytes", "text", "stream", "file" ], "description": "The bytes to set() in the replicated log: a byte array, or text, a stream or a file converted to bytes. A null body, a Map, a number or a POJO has no conversion to bytes and is skipped without an error: nothing is set" },
+    "producerOut": { "carriers": [ "bytes", "unchanged" ], "description": "The byte array the state machine returns for the set (an empty array with the default NopStateMachine), with the state of the raft in the headers. A body that was skipped is left as it was" }
+  },
   "properties": {
     "clusterName": { "index": 0, "kind": "path", "displayName": "Cluster Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the JGroupsraft cluster the component should connect to." },
     "enableRoleChangeEvents": { "index": 1, "kind": "parameter", "displayName": "Enable Role Change Events", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "If set to true, the consumer endpoint will receive roleChange event as well (not just connecting and\/or using the state machine). By default it is set to false." },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jgroups.json

@@ -39,6 +39,11 @@
     "CamelJGroupsSrc": { "index": 2, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "org.jgroups.Address", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Consumer : The org.jgroups.Address instance extracted by org.jgroups.Message.getSrc() method of the consumed message. Producer: The custom source org.jgroups.Address of the message to be sent.", "constantName": "org.apache.camel.component.jgroups.JGroupsConstants#HEADER_JGROUPS_SRC" },
     "CamelJGroupsOriginalMessage": { "index": 3, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "org.jgroups.Message", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The original org.jgroups.Message instance from which the body of the consumed message has been extracted.", "constantName": "org.apache.camel.component.jgroups.JGroupsConstants#HEADER_JGROUPS_ORIGINAL_MESSAGE" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "unknown" ], "dependsOn": [ "enableViewMessages" ], "description": "The object the sender put in the message, Java-deserialized: what a jgroups producer sent, such as a String, a byte array, a Map or a Serializable POJO, if the deserialization filter accepts its class. With enableViewMessages an org.jgroups.View also arrives on each change of the members of the cluster" },
+    "producerIn": { "carriers": [ "text", "bytes", "value", "map", "list", "file", "pojo" ], "description": "The body as is, Java-serialized into the message, so it must be Serializable: a stream or another object that is not fails with a NotSerializableException. A null body is not sent. The CamelJGroupsDest header sends it to one member instead of the cluster" },
+    "producerOut": { "carriers": [ "unchanged" ] }
+  },
   "properties": {
     "clusterName": { "index": 0, "kind": "path", "displayName": "Cluster Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the JGroups cluster the component should connect to." },
     "channelProperties": { "index": 1, "kind": "parameter", "displayName": "Channel Properties", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Specifies configuration properties of the JChannel used by the endpoint." },