From c34607d44934d6de53dfc0c7ac2be40fc5c6f1fc Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 17 Jun 2020 18:52:53 -0400 Subject: [PATCH] Metadata changes for new apps --- .../stream-applications-build/pom.xml | 5 ++ .../stream-applications-descriptor/pom.xml | 10 +++ .../META-INF/kafka-apps-docker.properties | 5 ++ .../kafka-apps-maven-repo-url.properties | 10 +++ .../META-INF/kafka-apps-maven.properties | 10 +++ .../META-INF/rabbit-apps-docker.properties | 5 ++ .../rabbit-apps-maven-repo-url.properties | 10 +++ .../META-INF/rabbit-apps-maven.properties | 10 +++ .../stream-applications-docs/pom.xml | 68 ++++++++++++++++++- .../src/main/asciidoc/sinks.adoc | 6 ++ .../src/main/asciidoc/sources.adoc | 9 +++ 11 files changed, 147 insertions(+), 1 deletion(-) diff --git a/applications/stream-applications-build/pom.xml b/applications/stream-applications-build/pom.xml index 7b93a5dc..41ea2044 100644 --- a/applications/stream-applications-build/pom.xml +++ b/applications/stream-applications-build/pom.xml @@ -20,15 +20,18 @@ 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT @@ -43,7 +46,9 @@ 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT + 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT 3.0.0-SNAPSHOT diff --git a/applications/stream-applications-build/stream-applications-descriptor/pom.xml b/applications/stream-applications-build/stream-applications-descriptor/pom.xml index 2453a8ca..d4605e88 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/pom.xml +++ b/applications/stream-applications-build/stream-applications-descriptor/pom.xml @@ -45,12 +45,16 @@ "${jdbc-source.version}".contains('-') ? 'repo.spring.io/milestone' : 'repo.spring.io/release' pom.properties['file-source-docker.tag']= "${file-source.version}".contains('SNAPSHOT') ? 'latest' : "${file-source.version}" + pom.properties['ftp-source-docker.tag']= + "${ftp-source.version}".contains('SNAPSHOT') ? 'latest' : "${ftp-source.version}" pom.properties['geode-source-docker.tag']= "${geode-source.version}".contains('SNAPSHOT') ? 'latest' : "${geode-source.version}" pom.properties['http-source-docker.tag']= "${http-source.version}".contains('SNAPSHOT') ? 'latest' : "${http-source.version}" pom.properties['jdbc-source-docker.tag']= "${jdbc-source.version}".contains('SNAPSHOT') ? 'latest' : "${jdbc-source.version}" + pom.properties['jms-source-docker.tag']= + "${jms-source.version}".contains('SNAPSHOT') ? 'latest' : "${jms-source.version}" pom.properties['load-generator-source-docker.tag']= "${load-generator-source.version}".contains('SNAPSHOT') ? 'latest' : "${load-generator-source.version}" pom.properties['mongodb-source-docker.tag']= @@ -63,6 +67,8 @@ "${tcp-source.version}".contains('SNAPSHOT') ? 'latest' : "${tcp-source.version}" pom.properties['time-source-docker.tag']= "${time-source.version}".contains('SNAPSHOT') ? 'latest' : "${time-source.version}" + pom.properties['websocket-source-docker.tag']= + "${websocket-source.version}".contains('SNAPSHOT') ? 'latest' : "${websocket-source.version}" pom.properties['cassandra-sink-docker.tag']= "${cassandra-sink.version}".contains('SNAPSHOT') ? 'latest' : "${cassandra-sink.version}" pom.properties['counter-sink-docker.tag']= @@ -93,6 +99,10 @@ "${tcp-sink.version}".contains('SNAPSHOT') ? 'latest' : "${tcp-sink.version}" pom.properties['throughput-sink-docker.tag']= "${throughput-sink.version}".contains('SNAPSHOT') ? 'latest' : "${throughput-sink.version}" + pom.properties['tasklauncher-sink-docker.tag']= + "${tasklauncher-sink.version}".contains('SNAPSHOT') ? 'latest' : "${tasklauncher-sink.version}" + pom.properties['websocket-sink-docker.tag']= + "${websocket-sink.version}".contains('SNAPSHOT') ? 'latest' : "${websocket-sink.version}" pom.properties['bridge-processor-docker.tag']= "${bridge-processor.version}".contains('SNAPSHOT') ? 'latest' : "${bridge-processor.version}" pom.properties['filter-processor-docker.tag']= diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties index 6f933406..dee68056 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-docker.properties @@ -1,13 +1,16 @@ source.file=docker:springcloudstream/file-source-kafka:@file-source-docker.tag@ +source.ftp=docker:springcloudstream/ftp-source-kafka:@ftp-source-docker.tag@ source.geode=docker:springcloudstream/geode-source-kafka:@geode-source-docker.tag@ source.http=docker:springcloudstream/http-source-kafka:@http-source-docker.tag@ source.jdbc=docker:springcloudstream/jdbc-source-kafka:@jdbc-source-docker.tag@ +source.jms=docker:springcloudstream/jms-source-kafka:@jms-source-docker.tag@ source.load-generator=docker:springcloudstream/load-generator-source-kafka:@load-generator-source-docker.tag@ source.mongodb=docker:springcloudstream/mongodb-source-kafka:@mongodb-source-docker.tag@ source.mqtt=docker:springcloudstream/mqtt-source-kafka:@mqtt-source-docker.tag@ source.rabbit=docker:springcloudstream/rabbit-source-kafka:@rabbit-source-docker.tag@ source.tcp=docker:springcloudstream/tcp-source-kafka:@tcp-source-docker.tag@ source.time=docker:springcloudstream/time-source-kafka:@time-source-docker.tag@ +source.websocket=docker:springcloudstream/websocket-source-kafka:@websocket-source-docker.tag@ sink.cassandra=docker:springcloudstream/cassandra-sink-kafka:@cassandra-sink-docker.tag@ sink.counter=docker:springcloudstream/counter-sink-kafka:@counter-sink-docker.tag@ sink.file=docker:springcloudstream/file-sink-kafka:@file-sink-docker.tag@ @@ -22,7 +25,9 @@ sink.redis=docker:springcloudstream/redis-sink-kafka:@redis-sink-docker.tag@ sink.router=docker:springcloudstream/router-sink-kafka:@router-sink-docker.tag@ sink.sftp=docker:springcloudstream/sftp-sink-kafka:@sftp-sink-docker.tag@ sink.tcp=docker:springcloudstream/tcp-sink-kafka:@tcp-sink-docker.tag@ +sink.tasklauncher=docker:springcloudstream/tasklauncher-sink-kafka:@tasklauncher-sink-docker.tag@ sink.throughput=docker:springcloudstream/throughput-sink-kafka:@throughput-sink-docker.tag@ +sink.websocket=docker:springcloudstream/websocket-sink-kafka:@websocket-sink-docker.tag@ processor.bridge=docker:springcloudstream/bridge-processor-kafka:@bridge-processor-docker.tag@ processor.filter=docker:springcloudstream/filter-processor-kafka:@filter-processor-docker.tag@ processor.groovy=docker:springcloudstream/groovy-processor-kafka:@groovy-processor-docker.tag@ diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties index 90160408..977765f1 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven-repo-url.properties @@ -1,11 +1,15 @@ source.file=https://@repo-spring-io@/org/springframework/cloud/stream/app/file-source-kafka/@file-source.version@/file-source-kafka-@file-source.version@.jar source.file.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/file-source-kafka/@file-source.version@/file-source-kafka-@file-source.version@-metadata.jar +source.ftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/ftp-source-kafka/@ftp-source.version@/ftp-source-kafka-@ftp-source.version@.jar +source.ftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/ftp-source-kafka/@ftp-source.version@/ftp-source-kafka-@ftp-source.version@-metadata.jar source.geode=https://@repo-spring-io@/org/springframework/cloud/stream/app/geode-source-kafka/@geode-source.version@/geode-source-kafka-@geode-source.version@.jar source.geode.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/geode-source-kafka/@geode-source.version@/geode-source-kafka-@geode-source.version@-metadata.jar source.http=https://@repo-spring-io@/org/springframework/cloud/stream/app/http-source-kafka/@http-source.version@/http-source-kafka-@http-source.version@.jar source.http.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/http-source-kafka/@http-source.version@/http-source-kafka-@http-source.version@-metadata.jar source.jdbc=https://@repo-spring-io@/org/springframework/cloud/stream/app/jdbc-source-kafka/@jdb-source.version@/jdbc-source-kafka-@jdbc-source.version@.jar source.jdbc.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/jdbc-source-kafka/@jdb-source.version@/jdbc-source-kafka-@jdbc-source.version@-metadata.jar +source.jms=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-source-kafka/@jms-source.version@/jms-source-kafka-@jms-source.version@.jar +source.jms.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-source-kafka/@jms-source.version@/jms-source-kafka-@jms-source.version@-metadata.jar source.load-generator=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-kafka/@load-generator-source.version@/load-generator-source-kafka-@load-generator-source.version@.jar source.load-generator.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-kafka/@load-generator-source.version@/load-generator-source-kafka-@load-generator-source.version@-metadata.jar source.mongodb=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-source-kafka/@mongodb-source.version@/mongodb-source-kafka-@mongodb-source.version@.jar @@ -18,6 +22,8 @@ source.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sou source.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-source-kafka/@tcp-source.version@/tcp-source-kafka-@tcp-source.version@-metadata.jar source.time=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-kafka/@time-source.version@/time-source-kafka-@time-source.version@.jar source.time.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-kafka/@time-source.version@/time-source-kafka-@time-source.version@-metadata.jar +source.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-kafka/@websocket-source.version@/websocket-source-kafka-@websocket-source.version@.jar +source.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-kafka/@websocket-source.version@/websocket-source-kafka-@websocket-source.version@-metadata.jar sink.cassandra=https://@repo-spring-io@/org/springframework/cloud/stream/app/cassandra-sink-kafka/@cassandra-sink.version@/cassandra-sink-kafka-@cassandra-sink.version@.jar sink.cassandra.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/cassandra-sink-kafka/@cassandra-sink.version@/cassandra-sink-kafka-@cassandra-sink.version@-metadata.jar sink.counter=https://@repo-spring-io@/org/springframework/cloud/stream/app/counter-sink-kafka/@counter-sink.version@/counter-sink-kafka-@counter-sink.version@.jar @@ -46,8 +52,12 @@ sink.sftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sin sink.sftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sink-kafka/@sftp-sink.version@/sftp-sink-kafka-@sftp-sink.version@-metadata.jar sink.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-kafka/@tcp-sink.version@/tcp-sink-kafka-@sftp-sink.version@.jar sink.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-kafka/@tcp-sink.version@/tcp-sink-kafka-@tcp-sink.version@-metadata.jar +sink.tasklauncher=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-kafka/@tasklauncher-sink.version@/tasklauncher-sink-kafka-@tasklauncher-sink.version@.jar +sink.tasklauncher.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-kafka/@tasklauncher-sink.version@/tasklauncher-sink-kafka-@tasklauncher-sink.version@-metadata.jar sink.throughput=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-kafka/@throughput-sink.version@/throughput-sink-kafka-@throughput-sink.version@.jar sink.throughput.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-kafka/@throughput-sink.version@/throughput-sink-kafka-@throughput-sink.version@-metadata.jar +sink.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-kafka/@websocket-sink.version@/websocket-sink-kafka-@websocket-sink.version@.jar +sink.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-kafka/@websocket-sink.version@/websocket-sink-kafka-@websocket-sink.version@-metadata.jar processor.bridge=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-kafka/@bridge-processor.version@/bridge-processor-kafka-@bridge-processor.version@.jar processor.bridge.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-kafka/@bridge-processor.version@/bridge-processor-kafka-@bridge-processor.version@-metadata.jar processor.filter=https://@repo-spring-io@/org/springframework/cloud/stream/app/filter-processor-kafka/@filter-processor.version@/filter-processor-kafka-@filter-processor.version@.jar diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties index b5ddbb86..6c7a564c 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/kafka-apps-maven.properties @@ -1,11 +1,15 @@ source.file=maven://org.springframework.cloud.stream.app:file-source-kafka:@file-source.version@ source.file.metadata=maven://org.springframework.cloud.stream.app:file-source-kafka:jar:metadata:@file-source.version@ +source.ftp=maven://org.springframework.cloud.stream.app:ftp-source-kafka:@ftp-source.version@ +source.ftp.metadata=maven://org.springframework.cloud.stream.app:ftp-source-kafka:jar:metadata:@ftp-source.version@ source.geode=maven://org.springframework.cloud.stream.app:geode-source-kafka:@geode-source.version@ source.geode.metadata=maven://org.springframework.cloud.stream.app:geode-source-kafka:jar:metadata:@geode-source.version@ source.http=maven://org.springframework.cloud.stream.app:http-source-kafka:@http-source.version@ source.http.metadata=maven://org.springframework.cloud.stream.app:http-source-kafka:jar:metadata:@http-source.version@ source.jdbc=maven://org.springframework.cloud.stream.app:jdbc-source-kafka:@jdbc-source.version@ source.jdbc.metadata=maven://org.springframework.cloud.stream.app:jdbc-source-kafka:jar:metadata:@jdbc-source.version@ +source.jms=maven://org.springframework.cloud.stream.app:jms-source-kafka:@jms-source.version@ +sourc.jms.metadata=maven://org.springframework.cloud.stream.app:jms-source-kafka:jar:metadata:@jms-source.version@ source.load-generator=maven://org.springframework.cloud.stream.app:load-generator-source-kafka:@load-generator-source.version@ source.load-generator.metadata=maven://org.springframework.cloud.stream.app:load-generator-source-kafka:jar:metadata:@load-generator-source.version@ source.mongodb=maven://org.springframework.cloud.stream.app:mongodb-source-kafka:@mongodb-source.version@ @@ -18,6 +22,8 @@ source.tcp=maven://org.springframework.cloud.stream.app:tcp-source-kafka:@tcp-so source.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-source-kafka:jar:metadata:@tcp-source.version@ source.time=maven://org.springframework.cloud.stream.app:time-source-kafka:@time-source.version@ source.time.metadata=maven://org.springframework.cloud.stream.app:time-source-kafka:jar:metadata:@time-source.version@ +source.websocket=maven://org.springframework.cloud.stream.app:websocket-source-kafka:@websocket-source.version@ +source.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-source-kafka:jar:metadata:@websocket-source.version@ sink.cassandra=maven://org.springframework.cloud.stream.app:cassandra-sink-kafka:@cassandra-sink.version@ sink.cassandra.metadata=maven://org.springframework.cloud.stream.app:cassandra-sink-kafka:jar:metadata:@cassandra-sink.version@ sink.counter=maven://org.springframework.cloud.stream.app:counter-sink-kafka:@counter-sink.version@ @@ -46,8 +52,12 @@ sink.sftp=maven://org.springframework.cloud.stream.app:sftp-sink-kafka:@sftp-sin sink.sftp.metadata=maven://org.springframework.cloud.stream.app:sftp-sink-kafka:jar:metadata:@sftp-sink.version@ sink.tcp=maven://org.springframework.cloud.stream.app:tcp-sink-kafka:@tcp-sink.version@ sink.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-sink-kafka:jar:metadata:@tcp-sink.version@ +sink.tasklauncher=maven://org.springframework.cloud.stream.app:tasklauncher-sink-kafka:@tasklauncher-sink.version@ +sink.tasklauncher.metadata=maven://org.springframework.cloud.stream.app:tasklauncher-sink-kafka:jar:metadata:@tasklauncher-sink.version@ sink.throughput=maven://org.springframework.cloud.stream.app:throughput-sink-kafka:@throughput-sink.version@ sink.throughput.metadata=maven://org.springframework.cloud.stream.app:throughput-sink-kafka:jar:metadata:@throughput-sink.version@ +sink.websocket=maven://org.springframework.cloud.stream.app:websocket-sink-kafka:@websocket-sink.version@ +sink.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-sink-kafka:jar:metadata:@websocket-sink.version@ processor.bridge=maven://org.springframework.cloud.stream.app:bridge-processor-kafka:@bridge-processor.version@ processor.bridge.metadata=maven://org.springframework.cloud.stream.app:bridge-processor-kafka:jar:metadata:@bridge-processor.version@ processor.filter=maven://org.springframework.cloud.stream.app:filter-processor-kafka:@filter-processor.version@ diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties index 032aa10d..bdf01802 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-docker.properties @@ -1,13 +1,16 @@ source.file=docker:springcloudstream/file-source-rabbit:@file-source-docker.tag@ +source.ftp=docker:springcloudstream/ftp-source-rabbit:@ftp-source-docker.tag@ source.geode=docker:springcloudstream/geode-source-rabbit:@geode-source-docker.tag@ source.http=docker:springcloudstream/http-source-rabbit:@http-source-docker.tag@ source.jdbc=docker:springcloudstream/jdbc-source-rabbit:@jdbc-source-docker.tag@ +source.jms=docker:springcloudstream/jms-source-rabbit:@jms-source-docker.tag@ source.load-generator=docker:springcloudstream/load-generator-source-rabbit:@load-generator-source-docker.tag@ source.mongodb=docker:springcloudstream/mongodb-source-rabbit:@mongodb-source-docker.tag@ source.mqtt=docker:springcloudstream/mqtt-source-rabbit:@mqtt-source-docker.tag@ source.rabbit=docker:springcloudstream/rabbit-source-rabbit:@rabbit-source-docker.tag@ source.tcp=docker:springcloudstream/tcp-source-rabbit:@tcp-source-docker.tag@ source.time=docker:springcloudstream/time-source-rabbit:@time-source-docker.tag@ +source.websocket=docker:springcloudstream/websocket-source-rabbit:@websocket-source-docker.tag@ sink.cassandra=docker:springcloudstream/cassandra-sink-rabbit:@cassandra-sink-docker.tag@ sink.counter=docker:springcloudstream/counter-sink-rabbit:@counter-sink-docker.tag@ sink.file=docker:springcloudstream/file-sink-rabbit:@file-sink-docker.tag@ @@ -22,7 +25,9 @@ sink.redis=docker:springcloudstream/redis-sink-rabbit:@redis-sink-docker.tag@ sink.router=docker:springcloudstream/router-sink-rabbit:@router-sink-docker.tag@ sink.sftp=docker:springcloudstream/sftp-sink-rabbit:@sftp-sink-docker.tag@ sink.tcp=docker:springcloudstream/tcp-sink-rabbit:@tcp-sink-docker.tag@ +sink.tasklauncher=docker:springcloudstream/tasklauncher-sink-rabbit:@tasklauncher-sink-docker.tag@ sink.throughput=docker:springcloudstream/throughput-sink-rabbit:@throughput-sink-docker.tag@ +sink.websocket=docker:springcloudstream/websocket-sink-rabbit:@websocket-sink-docker.tag@ processor.bridge=docker:springcloudstream/bridge-processor-rabbit:@bridge-processor-docker.tag@ processor.filter=docker:springcloudstream/filter-processor-rabbit:@filter-processor-docker.tag@ processor.groovy=docker:springcloudstream/groovy-processor-rabbit:@groovy-processor-docker.tag@ diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties index b64b93da..a40c0ef7 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven-repo-url.properties @@ -1,11 +1,15 @@ source.file=https://@repo-spring-io@/org/springframework/cloud/stream/app/file-source-rabbit/@file-source.version@/file-source-rabbit-@file-source.version@.jar source.file.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/file-source-rabbit/@file-source.version@/file-source-rabbit-@file-source.version@-metadata.jar +source.ftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/ftp-source-rabbit/@ftp-source.version@/ftp-source-rabbit-@ftp-source.version@.jar +source.ftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/ftp-source-rabbit/@ftp-source.version@/ftp-source-rabbit-@ftp-source.version@-metadata.jar source.geode=https://@repo-spring-io@/org/springframework/cloud/stream/app/geode-source-rabbit/@geode-source.version@/geode-source-rabbit-@geode-source.version@.jar source.geode.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/geode-source-rabbit/@geode-source.version@/geode-source-rabbit-@geode-source.version@-metadata.jar source.http=https://@repo-spring-io@/org/springframework/cloud/stream/app/http-source-rabbit/@http-source.version@/http-source-rabbit-@http-source.version@.jar source.http.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/http-source-rabbit/@http-source.version@/http-source-rabbit-@http-source.version@-metadata.jar source.jdbc=https://@repo-spring-io@/org/springframework/cloud/stream/app/jdbc-source-rabbit/@jdb-source.version@/jdbc-source-rabbit-@jdbc-source.version@.jar source.jdbc.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/jdbc-source-rabbit/@jdb-source.version@/jdbc-source-rabbit-@jdbc-source.version@-metadata.jar +source.jms=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-source-rabbit/@jms-source.version@/jms-source-rabbit-@jms-source.version@.jar +source.jms.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/jms-source-rabbit/@jms-source.version@/jms-source-rabbit-@jms-source.version@-metadata.jar source.load-generator=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-rabbit/@load-generator-source.version@/load-generator-source-rabbit-@load-generator-source.version@.jar source.load-generator.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/load-generator-source-rabbit/@load-generator-source.version@/load-generator-source-rabbit-@load-generator-source.version@-metadata.jar source.mongodb=https://@repo-spring-io@/org/springframework/cloud/stream/app/mongodb-source-rabbit/@mongodb-source.version@/mongodb-source-rabbit-@mongodb-source.version@.jar @@ -18,6 +22,8 @@ source.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sou source.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-source-rabbit/@tcp-source.version@/tcp-source-rabbit-@tcp-source.version@-metadata.jar source.time=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-rabbit/@time-source.version@/time-source-rabbit-@time-source.version@.jar source.time.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/time-source-rabbit/@time-source.version@/time-source-rabbit-@time-source.version@-metadata.jar +source.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-rabbit/@websocket-source.version@/websocket-source-rabbit-@websocket-source.version@.jar +source.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-source-rabbit/@websocket-source.version@/websocket-source-rabbit-@websocket-source.version@-metadata.jar sink.cassandra=https://@repo-spring-io@/org/springframework/cloud/stream/app/cassandra-sink-rabbit/@cassandra-sink.version@/cassandra-sink-rabbit-@cassandra-sink.version@.jar sink.cassandra.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/cassandra-sink-rabbit/@cassandra-sink.version@/cassandra-sink-rabbit-@cassandra-sink.version@-metadata.jar sink.counter=https://@repo-spring-io@/org/springframework/cloud/stream/app/counter-sink-rabbit/@counter-sink.version@/counter-sink-rabbit-@counter-sink.version@.jar @@ -46,8 +52,12 @@ sink.sftp=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sin sink.sftp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/sftp-sink-rabbit/@sftp-sink.version@/sftp-sink-rabbit-@sftp-sink.version@-metadata.jar sink.tcp=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-rabbit/@tcp-sink.version@/tcp-sink-rabbit-@sftp-sink.version@.jar sink.tcp.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tcp-sink-rabbit/@tcp-sink.version@/tcp-sink-rabbit-@tcp-sink.version@-metadata.jar +sink.tasklauncher=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-rabbit/@tasklauncher-sink.version@/tasklauncher-sink-rabbit-@tasklauncher-sink.version@.jar +sink.tasklauncher.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/tasklauncher-sink-rabbit/@tasklauncher-sink.version@/tasklauncher-sink-rabbit-@tasklauncher-sink.version@-metadata.jar sink.throughput=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-rabbit/@throughput-sink.version@/throughput-sink-rabbit-@throughput-sink.version@.jar sink.throughput.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/throughput-sink-rabbit/@throughput-sink.version@/throughput-sink-rabbit-@throughput-sink.version@-metadata.jar +sink.websocket=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-rabbit/@websocket-sink.version@/websocket-sink-rabbit-@websocket-sink.version@.jar +sink.websocket.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/websocket-sink-rabbit/@websocket-sink.version@/websocket-sink-rabbit-@websocket-sink.version@-metadata.jar processor.bridge=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-rabbit/@bridge-processor.version@/bridge-processor-rabbit-@bridge-processor.version@.jar processor.bridge.metadata=https://@repo-spring-io@/org/springframework/cloud/stream/app/bridge-processor-rabbit/@bridge-processor.version@/bridge-processor-rabbit-@bridge-processor.version@-metadata.jar processor.filter=https://@repo-spring-io@/org/springframework/cloud/stream/app/filter-processor-rabbit/@filter-processor.version@/filter-processor-rabbit-@filter-processor.version@.jar diff --git a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties index bc8f1865..58106822 100644 --- a/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties +++ b/applications/stream-applications-build/stream-applications-descriptor/src/main/resources/META-INF/rabbit-apps-maven.properties @@ -1,11 +1,15 @@ source.file=maven://org.springframework.cloud.stream.app:file-source-rabbit:@file-source.version@ source.file.metadata=maven://org.springframework.cloud.stream.app:file-source-rabbit:jar:metadata:@file-source.version@ +source.ftp=maven://org.springframework.cloud.stream.app:ftp-source-rabbit:@ftp-source.version@ +source.ftp.metadata=maven://org.springframework.cloud.stream.app:ftp-source-rabbit:jar:metadata:@ftp-source.version@ source.geode=maven://org.springframework.cloud.stream.app:geode-source-rabbit:@geode-source.version@ source.geode.metadata=maven://org.springframework.cloud.stream.app:geode-source-rabbit:jar:metadata:@geode-source.version@ source.http=maven://org.springframework.cloud.stream.app:http-source-rabbit:@http-source.version@ source.http.metadata=maven://org.springframework.cloud.stream.app:http-source-rabbit:jar:metadata:@http-source.version@ source.jdbc=maven://org.springframework.cloud.stream.app:jdbc-source-rabbit:@jdbc-source.version@ source.jdbc.metadata=maven://org.springframework.cloud.stream.app:jdbc-source-rabbit:jar:metadata:@jdbc-source.version@ +source.jms=maven://org.springframework.cloud.stream.app:jms-source-rabbit:@jms-source.version@ +sourc.jms.metadata=maven://org.springframework.cloud.stream.app:jms-source-rabbit:jar:metadata:@jms-source.version@ source.load-generator=maven://org.springframework.cloud.stream.app:load-generator-source-rabbit:@load-generator-source.version@ source.load-generator.metadata=maven://org.springframework.cloud.stream.app:load-generator-source-rabbit:jar:metadata:@load-generator-source.version@ source.mongodb=maven://org.springframework.cloud.stream.app:mongodb-source-rabbit:@mongodb-source.version@ @@ -18,6 +22,8 @@ source.tcp=maven://org.springframework.cloud.stream.app:tcp-source-rabbit:@tcp-s source.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-source-rabbit:jar:metadata:@tcp-source.version@ source.time=maven://org.springframework.cloud.stream.app:time-source-rabbit:@time-source.version@ source.time.metadata=maven://org.springframework.cloud.stream.app:time-source-rabbit:jar:metadata:@time-source.version@ +source.websocket=maven://org.springframework.cloud.stream.app:websocket-source-rabbit:@websocket-source.version@ +source.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-source-rabbit:jar:metadata:@websocket-source.version@ sink.cassandra=maven://org.springframework.cloud.stream.app:cassandra-sink-rabbit:@cassandra-sink.version@ sink.cassandra.metadata=maven://org.springframework.cloud.stream.app:cassandra-sink-rabbit:jar:metadata:@cassandra-sink.version@ sink.counter=maven://org.springframework.cloud.stream.app:counter-sink-rabbit:@counter-sink.version@ @@ -46,8 +52,12 @@ sink.sftp=maven://org.springframework.cloud.stream.app:sftp-sink-rabbit:@sftp-si sink.sftp.metadata=maven://org.springframework.cloud.stream.app:sftp-sink-rabbit:jar:metadata:@sftp-sink.version@ sink.tcp=maven://org.springframework.cloud.stream.app:tcp-sink-rabbit:@tcp-sink.version@ sink.tcp.metadata=maven://org.springframework.cloud.stream.app:tcp-sink-rabbit:jar:metadata:@tcp-sink.version@ +sink.tasklauncher=maven://org.springframework.cloud.stream.app:tasklauncher-sink-rabbit:@tasklauncher-sink.version@ +sink.tasklauncher.metadata=maven://org.springframework.cloud.stream.app:tasklauncher-sink-rabbit:jar:metadata:@tasklauncher-sink.version@ sink.throughput=maven://org.springframework.cloud.stream.app:throughput-sink-rabbit:@throughput-sink.version@ sink.throughput.metadata=maven://org.springframework.cloud.stream.app:throughput-sink-rabbit:jar:metadata:@throughput-sink.version@ +sink.websocket=maven://org.springframework.cloud.stream.app:websocket-sink-rabbit:@websocket-sink.version@ +sink.websocket.metadata=maven://org.springframework.cloud.stream.app:websocket-sink-rabbit:jar:metadata:@websocket-sink.version@ processor.bridge=maven://org.springframework.cloud.stream.app:bridge-processor-rabbit:@bridge-processor.version@ processor.bridge.metadata=maven://org.springframework.cloud.stream.app:bridge-processor-rabbit:jar:metadata:@bridge-processor.version@ processor.filter=maven://org.springframework.cloud.stream.app:filter-processor-rabbit:@filter-processor.version@ diff --git a/applications/stream-applications-build/stream-applications-docs/pom.xml b/applications/stream-applications-build/stream-applications-docs/pom.xml index d065481d..45e2473a 100644 --- a/applications/stream-applications-build/stream-applications-docs/pom.xml +++ b/applications/stream-applications-build/stream-applications-docs/pom.xml @@ -25,11 +25,48 @@ + + + org.springframework.cloud.fn + file-common + ${java-functions.version} + + + org.springframework.cloud.fn + ftp-common + ${java-functions.version} + + + org.springframework.cloud.fn + geode-common + ${java-functions.version} + + + org.springframework.cloud.fn + metadata-store-common + ${java-functions.version} + + + org.springframework.cloud.fn + mqtt-common + ${java-functions.version} + + + org.springframework.cloud.fn + tcp-common + ${java-functions.version} + + org.springframework.cloud.fn file-supplier ${java-functions.version} + + org.springframework.cloud.fn + ftp-supplier + ${java-functions.version} + org.springframework.cloud.fn geode-supplier @@ -45,7 +82,11 @@ jdbc-supplier ${java-functions.version} - + + org.springframework.cloud.fn + jms-supplier + ${java-functions.version} + org.springframework.cloud.fn mongodb-supplier @@ -71,6 +112,12 @@ time-supplier ${java-functions.version} + + org.springframework.cloud.fn + websocket-supplier + ${java-functions.version} + + org.springframework.cloud.fn cassandra-consumer @@ -141,6 +188,12 @@ tcp-consumer ${java-functions.version} + + org.springframework.cloud.fn + websocket-consumer + ${java-functions.version} + + org.springframework.cloud.fn header-enricher-function @@ -161,6 +214,11 @@ splitter-function ${java-functions.version} + + org.springframework.cloud.fn + tasklauncher-function + ${java-functions.version} + org.springframework.cloud.stream.app @@ -182,6 +240,14 @@ script-processor ${script-processor.version} + + + + org.springframework.cloud.stream.app + tasklauncher-sink + ${tasklauncher-sink.version} + + diff --git a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc index f32c0247..6a91a8b8 100644 --- a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc +++ b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sinks.adoc @@ -45,7 +45,13 @@ include::{stream-apps-root}/{branch}/applications/sink/sftp-sink/README.adoc[tag [[spring-cloud-stream-modules-tcp-sink]] include::{stream-apps-root}/{branch}/applications/sink/tcp-sink/README.adoc[tags=ref-doc] +[[spring-cloud-stream-modules-tasklauncher-sink]] +include::{stream-apps-root}/{branch}/applications/sink/tasklauncher-sink/README.adoc[tags=ref-doc] + [[spring-cloud-stream-modules-throughput-sink]] include::{stream-apps-root}/{branch}/applications/sink/throughput-sink/README.adoc[tags=ref-doc] +[[spring-cloud-stream-modules-websocket-sink]] +include::{stream-apps-root}/{branch}/applications/sink/websocket-sink/README.adoc[tags=ref-doc] + :leveloffset: -2 diff --git a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc index 5ab97d9b..4c99633e 100644 --- a/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc +++ b/applications/stream-applications-build/stream-applications-docs/src/main/asciidoc/sources.adoc @@ -6,6 +6,9 @@ [[spring-cloud-stream-modules-file-source]] include::{stream-apps-root}/{branch}/applications/source/file-source/README.adoc[tags=ref-doc] +[[spring-cloud-stream-modules-ftp-source]] +include::{stream-apps-root}/{branch}/applications/source/ftp-source/README.adoc[tags=ref-doc] + [[spring-cloud-stream-modules-geode-source]] include::{stream-apps-root}/{branch}/applications/source/geode-source/README.adoc[tags=ref-doc] @@ -15,6 +18,9 @@ include::{stream-apps-root}/{branch}/applications/source/http-source/README.adoc [[spring-cloud-stream-modules-jdbc-source]] include::{stream-apps-root}/{branch}/applications/source/jdbc-source/README.adoc[tags=ref-doc] +[[spring-cloud-stream-modules-jms-source]] +include::{stream-apps-root}/{branch}/applications/source/jms-source/README.adoc[tags=ref-doc] + [[spring-cloud-stream-modules-load-generator-source]] include::{stream-apps-root}/{branch}/applications/source/load-generator-source/README.adoc[tags=ref-doc] @@ -33,5 +39,8 @@ include::{stream-apps-root}/{branch}/applications/source/tcp-source/README.adoc[ [[spring-cloud-stream-modules-time-source]] include::{stream-apps-root}/{branch}/applications/source/time-source/README.adoc[tags=ref-doc] +[[spring-cloud-stream-modules-websocket-source]] +include::{stream-apps-root}/{branch}/applications/source/websocket-source/README.adoc[tags=ref-doc] + :leveloffset: -2