SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

interim

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-07-30 13:35:19 +02:00
parent 9aeebcc502
commit ff632a476e
2 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-cloud-stream-binder-rabbit-deployer/pom.xml
View File

@@ -17,7 +17,6 @@
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-rabbit</artifactId>
<!-- <version>${project.version}</version> -->
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>

16
spring-cloud-stream-binder-rabbit-deployer/src/main/java/org/springframework/cloud/stream/binder/rabbit/deployer/RabbitDeployer.java
View File

@@ -34,7 +34,6 @@ public class RabbitDeployer {
public static void main(String[] args) {
SpringApplication.run(RabbitDeployer.class,
//target/it/bootjar/target/bootjar-1.0.0.RELEASE-exec.jar
"--spring.cloud.function.definition=reverseFunction;echo",
"--spring.cloud.function.location=/Users/ozhurakousky/dev/repo/spring-cloud-function/spring-cloud-function-deployer/target/it/bootjar/target/bootjar-1.0.0.RELEASE-exec.jar",
@@ -44,7 +43,22 @@ public class RabbitDeployer {
@Bean
public Function<String, String> echo() {
// java -jar timesource-kafka.jar
// java -jar rabbit-bundle.jar -Dspring.cloud.function.location=.....jar
// java -jar rabbit-kafka-bundle.jar -Dspring.cloud.function.location=.....jar
// java -jar rabbit-rsocket-bundle.jar = GATEWAY
return v -> v;
}
// Step-1 - rabbit-bundle.jar(time) | rabbit-bundle.jar(log) - Step One - local
// Step-2 - polyglot
// Step-3 - SCDF
// Step-4 - Kubernetes
//http | rabbit-rsocket-bundle.jar(producer) | python | rabbit-rsocket-bundle.jar(consumer) | rabbit-bundle.jar(log)
//http => pyjon
}