From ac13dd74395984eb7f6a5d3da0dfee6bf506d8c8 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 21 Mar 2022 18:11:59 +0100 Subject: [PATCH] Make s-c-function deployer optional dependency --- spring-cloud-stream-binder-rabbit/pom.xml | 1 + .../stream/binder/rabbit/RabbitMessageChannelBinder.java | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/spring-cloud-stream-binder-rabbit/pom.xml b/spring-cloud-stream-binder-rabbit/pom.xml index 6bead1e02..ea0c5c47b 100644 --- a/spring-cloud-stream-binder-rabbit/pom.xml +++ b/spring-cloud-stream-binder-rabbit/pom.xml @@ -18,6 +18,7 @@ org.springframework.cloud spring-cloud-function-deployer ${spring-cloud-function.version} + true org.springframework.cloud diff --git a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java index 98197b58c..6c4ac6e11 100644 --- a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java +++ b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java @@ -217,6 +217,10 @@ public class RabbitMessageChannelBinder extends this.decompressingPostProcessor = decompressingPostProcessor; } + public String getProtocolIdentifier() { + return "amqp"; + } + /** * Set a {@link org.springframework.amqp.core.MessagePostProcessor} to compress * messages. Defaults to a