Hi @Mike13 ,
Weird, it’s working for me. Are you getting any sort of errors on app startup? I’m trying to think of a reason it wouldn’t actually send the message. This what I did just to try it out in a simple app:
Version info from pom
<properties>
<java.version>11</java.version>
<solace-spring-cloud.version>1.1.1</solace-spring-cloud.version>
<spring-cloud.version>Hoxton.SR8</spring-cloud.version>
</properties>
@SpringBootApplication
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
@Bean
public Supplier<String> supplier(){
return () -> {
System.out.println("Sending Hello World");
return "Hello World";
};
}
spring:
cloud:
function:
definition: supplier
stream:
bindings:
supplier-out-0:
destination: output/test
solace:
bindings:
supplier-out-0:
producer:
msgTtl: 23000
And then listening with sdkperf I can see the messages with the TTL set:
