From ff632a476e3b3f9feca17f0e2310c8b58a933547 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Fri, 30 Jul 2021 13:35:19 +0200
Subject: [PATCH] interim

---
 .../pom.xml                                      |  1 -
 .../binder/rabbit/deployer/RabbitDeployer.java   | 16 +++++++++++++++-
 2 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/spring-cloud-stream-binder-rabbit-deployer/pom.xml b/spring-cloud-stream-binder-rabbit-deployer/pom.xml
index 954dd7d2a..21cbfd17a 100644
--- a/spring-cloud-stream-binder-rabbit-deployer/pom.xml
+++ b/spring-cloud-stream-binder-rabbit-deployer/pom.xml
@@ -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>
diff --git a/spring-cloud-stream-binder-rabbit-deployer/src/main/java/org/springframework/cloud/stream/binder/rabbit/deployer/RabbitDeployer.java b/spring-cloud-stream-binder-rabbit-deployer/src/main/java/org/springframework/cloud/stream/binder/rabbit/deployer/RabbitDeployer.java
index 75d2eeda2..d3d5341ff 100644
--- a/spring-cloud-stream-binder-rabbit-deployer/src/main/java/org/springframework/cloud/stream/binder/rabbit/deployer/RabbitDeployer.java
+++ b/spring-cloud-stream-binder-rabbit-deployer/src/main/java/org/springframework/cloud/stream/binder/rabbit/deployer/RabbitDeployer.java
@@ -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
+
 }