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
commit fc8f63b6d1333bf3bd83b3da1c55b6740937d681 Author: Marat Gubaidullin <[email protected]> AuthorDate: Wed Feb 21 12:26:33 2024 -0500 Generator for #1105 --- karavan-core/src/core/model/CamelDefinition.ts | 8 ++++---- karavan-core/src/core/model/CamelMetadata.ts | 15 +++++++++++++++ 2 files changed, 19 insertions(+), 4 deletions(-) diff --git a/karavan-core/src/core/model/CamelDefinition.ts b/karavan-core/src/core/model/CamelDefinition.ts index 552e070a..f8d2e0a7 100644 --- a/karavan-core/src/core/model/CamelDefinition.ts +++ b/karavan-core/src/core/model/CamelDefinition.ts @@ -1807,11 +1807,11 @@ export class RegistryBeanDefinition extends CamelElement { } export class BatchResequencerConfig extends CamelElement { - allowDuplicates?: boolean; batchSize?: number; batchTimeout?: string; - ignoreInvalidExchanges?: boolean; + allowDuplicates?: boolean; reverse?: boolean; + ignoreInvalidExchanges?: boolean; public constructor(init?: Partial<BatchResequencerConfig>) { super('BatchResequencerConfig'); Object.assign(this, init); @@ -1820,11 +1820,11 @@ export class BatchResequencerConfig extends CamelElement { export class StreamResequencerConfig extends CamelElement { capacity?: number; - comparator?: string; + timeout?: string; deliveryAttemptInterval?: string; ignoreInvalidExchanges?: boolean; rejectOld?: boolean; - timeout?: string; + comparator?: string; public constructor(init?: Partial<StreamResequencerConfig>) { super('StreamResequencerConfig'); Object.assign(this, init); diff --git a/karavan-core/src/core/model/CamelMetadata.ts b/karavan-core/src/core/model/CamelMetadata.ts index 32ffd126..1a8af955 100644 --- a/karavan-core/src/core/model/CamelMetadata.ts +++ b/karavan-core/src/core/model/CamelMetadata.ts @@ -1903,6 +1903,21 @@ export const CamelModelMetadata: ElementMeta[] = [ new PropertyMeta('properties', 'Properties', "Optional properties to set on the created bean.", 'object', '', '', false, false, false, false, '', ''), new PropertyMeta('script', 'Script', "The script to execute that creates the bean when using scripting languages. If the script use the prefix resource: such as resource:classpath:com/foo/myscript.groovy, resource:file:/var/myscript.groovy, then its loaded from the external resource.", 'string', '', '', false, false, false, false, 'advanced', ''), ]), + new ElementMeta('batchConfig', 'BatchResequencerConfig', 'Batch Config', "Configures batch-processing resequence eip.", 'configuration,eip', [ + new PropertyMeta('batchSize', 'Batch Size', "Sets the size of the batch to be re-ordered. The default size is 100.", 'number', '', '100', false, false, false, false, '', ''), + new PropertyMeta('batchTimeout', 'Batch Timeout', "Sets the timeout for collecting elements to be re-ordered. The default timeout is 1000 msec.", 'string', '', '1000', false, false, false, false, '', ''), + new PropertyMeta('allowDuplicates', 'Allow Duplicates', "Whether to allow duplicates.", 'boolean', '', 'false', false, false, false, false, 'advanced', ''), + new PropertyMeta('reverse', 'Reverse', "Whether to reverse the ordering.", 'boolean', '', 'false', false, false, false, false, 'advanced', ''), + new PropertyMeta('ignoreInvalidExchanges', 'Ignore Invalid Exchanges', "Whether to ignore invalid exchanges", 'boolean', '', 'false', false, false, false, false, 'advanced', ''), + ]), + new ElementMeta('streamConfig', 'StreamResequencerConfig', 'Stream Config', "Configures stream-processing resequence eip.", 'configuration,eip', [ + new PropertyMeta('capacity', 'Capacity', "Sets the capacity of the resequencer inbound queue.", 'number', '', '1000', false, false, false, false, '', ''), + new PropertyMeta('timeout', 'Timeout', "Sets minimum time (milliseconds) to wait for missing elements (messages).", 'string', '', '1000', false, false, false, false, '', ''), + new PropertyMeta('deliveryAttemptInterval', 'Delivery Attempt Interval', "Sets the interval in milliseconds the stream resequencer will at most wait while waiting for condition of being able to deliver.", 'string', '', '1000', false, false, false, false, 'advanced', ''), + new PropertyMeta('ignoreInvalidExchanges', 'Ignore Invalid Exchanges', "Whether to ignore invalid exchanges", 'boolean', '', 'false', false, false, false, false, 'advanced', ''), + new PropertyMeta('rejectOld', 'Reject Old', "If true, throws an exception when messages older than the last delivered message are processed", 'boolean', '', 'false', false, false, false, false, 'advanced', ''), + new PropertyMeta('comparator', 'Comparator', "To use a custom comparator as a org.apache.camel.processor.resequencer.ExpressionResultComparator type.", 'string', '', '', false, false, false, false, 'advanced', ''), + ]), new ElementMeta('dataFormats', 'DataFormatsDefinition', 'Data formats', "Configure data formats.", 'dataformat,transformation', [ new PropertyMeta('asn1', 'asn1', "asn1", 'ASN1DataFormat', '', '', false, false, false, true, '', ''), new PropertyMeta('avro', 'avro', "avro", 'AvroDataFormat', '', '', false, false, false, true, '', ''),
