Skip to content

Commit c60bda2

Browse files
boolivarboolivar
committed
feat(int-aws): kpl-outbound-channel-adapter xsd schema
1 parent 4cbf182 commit c60bda2

File tree

1 file changed

+132
-0
lines changed

1 file changed

+132
-0
lines changed

‎int-aws/src/main/resources/org/springframework/schema/integration/aws/spring-integration-aws.xsd‎

Lines changed: 132 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -448,6 +448,138 @@
448448
</xsd:complexType>
449449
</xsd:element>
450450

451+
<xsd:element name="kpl-outbound-channel-adapter">
452+
<xsd:annotation>
453+
<xsd:documentation><![CDATA[
454+
Defines an outbound 'KplMessageHandler' adapter
455+
for sending data to Amazon Kinesis streams
456+
using Amazon Kinesis Producer Library.
457+
]]></xsd:documentation>
458+
</xsd:annotation>
459+
<xsd:complexType>
460+
<xsd:complexContent>
461+
<xsd:extension base="outboundChannelAdapter">
462+
<xsd:attributeGroup ref="integration:channelAdapterAttributes"/>
463+
<xsd:attribute name="kinesis-producer" type="xsd:string" use="required">
464+
<xsd:annotation>
465+
<xsd:documentation><![CDATA[
466+
The 'org.springframework.integration.aws.outbound.KinesisProducer' bean reference.
467+
]]></xsd:documentation>
468+
<xsd:appinfo>
469+
<tool:annotation kind="ref">
470+
<tool:expected-type type="org.springframework.integration.aws.outbound.KinesisProducer"/>
471+
</tool:annotation>
472+
</xsd:appinfo>
473+
</xsd:annotation>
474+
</xsd:attribute>
475+
<xsd:attribute name="stream" type="xsd:string">
476+
<xsd:annotation>
477+
<xsd:documentation><![CDATA[
478+
The name of the stream to put the data record into.
479+
Mutually exclusive with 'stream-expression'.
480+
]]></xsd:documentation>
481+
</xsd:annotation>
482+
</xsd:attribute>
483+
<xsd:attribute name="stream-expression" type="xsd:string">
484+
<xsd:annotation>
485+
<xsd:documentation><![CDATA[
486+
The name of the stream to put the data record into.
487+
Mutually exclusive with 'stream'.
488+
]]></xsd:documentation>
489+
</xsd:annotation>
490+
</xsd:attribute>
491+
<xsd:attribute name="partition-key" type="xsd:string">
492+
<xsd:annotation>
493+
<xsd:documentation><![CDATA[
494+
Determines which shard in the stream the data record is assigned to.
495+
Mutually exclusive with 'partition-key-expression'.
496+
]]></xsd:documentation>
497+
</xsd:annotation>
498+
</xsd:attribute>
499+
<xsd:attribute name="partition-key-expression" type="xsd:string">
500+
<xsd:annotation>
501+
<xsd:documentation><![CDATA[
502+
Determines which shard in the stream the data record is assigned to.
503+
Mutually exclusive with 'partition-key'.
504+
]]></xsd:documentation>
505+
</xsd:annotation>
506+
</xsd:attribute>
507+
<xsd:attribute name="explicit-hash-key" type="xsd:string">
508+
<xsd:annotation>
509+
<xsd:documentation><![CDATA[
510+
The hash value used to explicitly determine the shard
511+
the data record is assigned to by overriding the partition key hash.
512+
Mutually exclusive with 'explicit-hash-key-expression'.
513+
]]></xsd:documentation>
514+
</xsd:annotation>
515+
</xsd:attribute>
516+
<xsd:attribute name="explicit-hash-key-expression" type="xsd:string">
517+
<xsd:annotation>
518+
<xsd:documentation><![CDATA[
519+
The hash value used to explicitly determine the shard
520+
the data record is assigned to by overriding the partition key hash.
521+
Mutually exclusive with 'explicit-hash-key'.
522+
]]></xsd:documentation>
523+
</xsd:annotation>
524+
</xsd:attribute>
525+
<xsd:attribute name="sequence-number-expression" type="xsd:string">
526+
<xsd:annotation>
527+
<xsd:documentation><![CDATA[
528+
Guarantees strictly increasing sequence numbers,
529+
for puts from the same client and to the same partition key.
530+
If this parameter is not set, records
531+
are coarsely ordered based on arrival time.
532+
]]></xsd:documentation>
533+
</xsd:annotation>
534+
</xsd:attribute>
535+
<xsd:attribute name="embedded-headers-mapper" type="xsd:string">
536+
<xsd:annotation>
537+
<xsd:documentation><![CDATA[
538+
'org.springframework.integration.mapping.OutboundMessageMapper<byte[]>' bean reference
539+
for embedding message headers into the record data together with payload.
540+
]]></xsd:documentation>
541+
<xsd:appinfo>
542+
<tool:annotation kind="ref">
543+
<tool:expected-type type="org.springframework.integration.mapping.OutboundMessageMapper"/>
544+
</tool:annotation>
545+
</xsd:appinfo>
546+
</xsd:annotation>
547+
</xsd:attribute>
548+
<xsd:attribute name="message-converter" type="xsd:string">
549+
<xsd:annotation>
550+
<xsd:documentation><![CDATA[
551+
'org.springframework.messaging.converter.MessageConverter' bean reference
552+
for converting payload to 'byte[]' for Kinesis record.
553+
]]></xsd:documentation>
554+
<xsd:appinfo>
555+
<tool:annotation kind="ref">
556+
<tool:expected-type type="org.springframework.messaging.converter.MessageConverter"/>
557+
</tool:annotation>
558+
</xsd:appinfo>
559+
</xsd:annotation>
560+
</xsd:attribute>
561+
<xsd:attribute name="flush-duration" type="xsd:long">
562+
<xsd:annotation>
563+
<xsd:documentation><![CDATA[
564+
Rate in milliseconds how often to
565+
call a 'KinesisProducer.flush()'.
566+
Default is flush every record.
567+
]]></xsd:documentation>
568+
</xsd:annotation>
569+
</xsd:attribute>
570+
<xsd:attribute name="glue-schema-expression" type="xsd:string">
571+
<xsd:annotation>
572+
<xsd:documentation><![CDATA[
573+
SpEL expression for 'org.springframework.integration.aws.outbound.Schema'
574+
to add into a 'UserRecord' built from the request message.
575+
]]></xsd:documentation>
576+
</xsd:annotation>
577+
</xsd:attribute>
578+
</xsd:extension>
579+
</xsd:complexContent>
580+
</xsd:complexType>
581+
</xsd:element>
582+
451583
<xsd:element name="s3-inbound-channel-adapter">
452584
<xsd:annotation>
453585
<xsd:documentation><![CDATA[

0 commit comments

Comments
 (0)