New sample for Spring Cloud Stream RabbitMQ Binder

Adding the necessary Rabbit binder hints

Author: sobychacko

samples/cloud-stream-rabbit/.gitignore

@@ -0,0 +1,33 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

samples/cloud-stream-rabbit/README.md

@@ -0,0 +1,20 @@
+## Spring Cloud Stream Rabbit Binder Native Sample App
+
+To build and run the native application on the JVM:
+
+```
+mvn clean spring-boot:build-image
+docker-compose up
+java -jar target/cloud-stream-rabbit-0.0.1-SNAPSHOT.jar
+```
+
+To build the application as a native image:
+
+```
+mvn -Pnative -DskipTests package
+docker-compose up
+./target/cloud-stream-rabbit
+```
+
+As an alternative, you can use `build.sh` script that is provided as part of this sample application directory.
+This script will start RabbitMQ in a docker container, build the image, run the test that verifies the sample works as expected and then stop the docker container. 

samples/cloud-stream-rabbit/build.sh

@@ -0,0 +1,9 @@
+#!/usr/bin/env bash
+
+RC=0
+
+docker-compose up -d rabbitmq
+${PWD%/*samples/*}/scripts/compileWithMaven.sh && ${PWD%/*samples/*}/scripts/test.sh || RC=$?
+docker-compose down
+
+exit $RC

samples/cloud-stream-rabbit/docker-compose.yml

@@ -0,0 +1,6 @@
+version: '3'
+services:
+  rabbitmq:
+    image: rabbitmq
+    ports:
+      - 5672:5672

samples/cloud-stream-rabbit/pom.xml

@@ -0,0 +1,67 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+		 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+		 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>org.springframework.experimental</groupId>
+		<artifactId>spring-native-sample-parent</artifactId>
+		<version>0.10.6-SNAPSHOT</version>
+		<relativePath>../maven-parent/pom.xml</relativePath>
+	</parent>
+	<groupId>com.example</groupId>
+	<artifactId>cloud-stream-rabbit</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<name>rabbit</name>
+	<description>GraalVM Spring Cloud Stream Rabbit Binder Demo</description>
+
+	<properties>
+		<java.version>1.8</java.version>
+		<main.class>com.example.demo.SpringCloudStreamRabbitApplication</main.class>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.experimental</groupId>
+			<artifactId>spring-native</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-stream-binder-rabbit</artifactId>
+			<version>3.1.6-SNAPSHOT</version>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.experimental</groupId>
+				<artifactId>spring-aot-maven-plugin</artifactId>
+				<configuration>
+					<removeYamlSupport>true</removeYamlSupport>
+				</configuration>
+			</plugin>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<configuration>
+					<source>8</source>
+					<target>8</target>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>

samples/cloud-stream-rabbit/src/main/java/com/example/demo/SpringCloudStreamRabbitApplication.java

@@ -0,0 +1,48 @@
+package com.example.demo;
+
+import java.util.Random;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Supplier;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.stream.function.StreamBridge;
+import org.springframework.context.annotation.Bean;
+
+@SpringBootApplication
+public class SpringCloudStreamRabbitApplication {
+
+	@Autowired
+	StreamBridge streamBridge;
+
+	public static void main(String[] args) {
+		SpringApplication.run(SpringCloudStreamRabbitApplication.class, args);
+	}
+
+	@Bean
+	public Function<String, String> graalUppercaseFunction() {
+		return String::toUpperCase;
+	}
+
+	@Bean
+	public Consumer<String> graalLoggingConsumer() {
+		return s -> {
+			System.out.println("++++++Received:" + s);
+			// Verifying that StreamBridge API works in native applications.
+			streamBridge.send("sb-out", s);
+		};
+	}
+
+	@Bean
+	public Supplier<String> graalSupplier() {
+		return () -> {
+			String woodchuck = "How much wood a woodchuck chuck if a woodchuck could chuck wood?";
+			final String[] splitWoodchuck = woodchuck.split(" ");
+			Random random = new Random();
+			return splitWoodchuck[random.nextInt(splitWoodchuck.length)];
+		};
+	}
+
+}

samples/cloud-stream-rabbit/src/main/resources/application.properties

@@ -0,0 +1,5 @@
+spring.cloud.function.definition=graalSupplier;graalUppercaseFunction;graalLoggingConsumer
+
+spring.cloud.stream.bindings.graalLoggingConsumer-in-0.destination=graalUppercaseFunction-out-0
+
+spring.cloud.stream.bindings.graalSupplier-out-0.destination=graalUppercaseFunction-in-0

samples/cloud-stream-rabbit/verify.sh

@@ -0,0 +1,7 @@
+#!/usr/bin/env bash
+sleep 2
+if [[ `cat target/native/test-output.txt | grep -E "Received:(HOW|MUCH|WOOD|A|WOODCHUCK|CHUCK|IF|COULD|WOULD?)"` ]]; then
+	exit 0
+else
+	exit 1
+fi

spring-native-configuration/pom.xml

@@ -67,6 +67,11 @@
             <artifactId>spring-cloud-stream-binder-kafka</artifactId>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
+            <scope>provided</scope>
+        </dependency>
         <dependency>
             <groupId>org.springframework.batch</groupId>
             <artifactId>spring-batch-core</artifactId>

spring-native-configuration/src/main/java/org/springframework/cloud/stream/rabbit/RabbitBinderHints.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright 2019-2021 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.stream.rabbit;
+
+import org.springframework.cloud.stream.binder.rabbit.config.RabbitServiceAutoConfiguration;
+import org.springframework.cloud.stream.function.FunctionConfiguration;
+import org.springframework.nativex.hint.NativeHint;
+import org.springframework.nativex.hint.TypeHint;
+import org.springframework.nativex.type.NativeConfiguration;
+
+@NativeHint(trigger = FunctionConfiguration.class,
+		types = {
+				@TypeHint(types = {
+						RabbitServiceAutoConfiguration.class})
+		})
+
+public class RabbitBinderHints implements NativeConfiguration {
+}

spring-native-configuration/src/main/resources/META-INF/services/org.springframework.nativex.type.NativeConfiguration

@@ -99,6 +99,7 @@ org.springframework.cloud.loadbalancer.LoadBalancerHints
 org.springframework.cloud.netflix.eureka.EurekaClientHints
 org.springframework.cloud.sleuth.TraceHints
 org.springframework.cloud.stream.kafka.KafkaBinderHints
+org.springframework.cloud.stream.rabbit.RabbitBinderHints
 org.springframework.cloud.task.CloudTaskHints
 org.springframework.context.annotation.ContextAnnotationHints
 org.springframework.core.annotation.CoreAnnotationHints