Enhance cloud-stream-rabbit/kafka tests

- Add multi-binder with complex property for rabbit
- Add complex property for kafka

See https://github.com/spring-cloud/spring-cloud-stream/issues/2690
This commit is contained in:
Chris Bono
2024-05-15 21:57:55 -05:00
committed by Andy Wilkinson
parent 3b5c4c4bff
commit 68efb9472e
2 changed files with 39 additions and 12 deletions

View File

@@ -11,3 +11,9 @@ spring.cloud:
destination: graalUppercaseFunction-in-0
graalLoggingConsumer-in-0:
destination: graalUppercaseFunction-out-0
kafka:
bindings:
graalSupplier-out-0:
producer:
# ensures conversion service set on child context
send-timeout-expression: '''5m'''

View File

@@ -1,13 +1,34 @@
spring.main.web-application-type: none
spring.rabbitmq:
host: "${RABBITMQ_HOST:localhost}"
port: "${RABBITMQ_PORT_5672:5672}"
spring.cloud:
function:
definition: graalSupplier;graalUppercaseFunction;graalLoggingConsumer
stream:
bindings:
graalSupplier-out-0:
destination: graalUppercaseFunction-in-0
graalLoggingConsumer-in-0:
destination: graalUppercaseFunction-out-0
spring:
cloud:
function:
definition: graalSupplier;graalUppercaseFunction;graalLoggingConsumer
stream:
binders:
binder1:
type: rabbit
environment:
spring.rabbitmq:
host: "${RABBITMQ_HOST:localhost}"
port: "${RABBITMQ_PORT_5672:5672}"
binder2:
type: rabbit
environment:
spring.rabbitmq:
host: "${RABBITMQ_HOST:localhost}"
port: "${RABBITMQ_PORT_5672:5672}"
default-binder: binder1
bindings:
graalSupplier-out-0:
destination: graalUppercaseFunction-in-0
binder: binder1
graalLoggingConsumer-in-0:
destination: graalUppercaseFunction-out-0
binder: binder2
rabbit:
bindings:
graalSupplier-out-0:
producer:
# ensures conversion service set on child context
routing-key-expression: '''events.in'''