git.gumartinm.name Git - JavaForFun/blob

   1 package de.example.spring.kafka;
   2
   3 import org.slf4j.Logger;
   4 import org.slf4j.LoggerFactory;
   5 import org.springframework.cloud.stream.messaging.Source;
   6 import org.springframework.messaging.support.MessageBuilder;
   7
   8 import javax.inject.Inject;
   9
  10 public class Sender {
  11   private static final Logger LOGGER = LoggerFactory.getLogger(Sender.class);
  12
  13   // Aquí podrías haber usado tu custom interface: InputOutputChannels :)
  14   private final Source source;
  15
  16   @Inject
  17   public Sender(Source source) {
  18     this.source = source;
  19   }
  20
  21   public void sendMessage(String message) {
  22     source.output().send(MessageBuilder.withPayload(message).build());
  23   }
  24 }