Answers for "test spring cloud stream"

0

test spring cloud stream

@SpringBootApplication
@EnableBinding(Sink.class)
public class JdbcSink {

  @Bean
  @ServiceActivator(inputChannel = Sink.INPUT)
  public MessageHandler logHandler(DataSource dataSource) {
     return new JdbcMessageHandler(dataSource,
                                 "INSERT INTO foobar (value) VALUES (:payload)");
  }
}Copy
Posted by: Guest on April-24-2021

Code answers related to "test spring cloud stream"

Browse Popular Code Answers by Language