git.gumartinm.name Git - JavaForFun/blob

   1 package de.example.spring.kafka;
   2
   3 import org.springframework.cloud.stream.annotation.Input;
   4 import org.springframework.cloud.stream.annotation.Output;
   5 import org.springframework.messaging.MessageChannel;
   6 import org.springframework.messaging.SubscribableChannel;
   7
   8 /**
   9  * En lugar de esta definicion "custom" usaremos las dos que
  10  * vienen por defecto en:
  11  * org.springframework.cloud.stream.messaging.Sink
  12  * org.springframework.cloud.stream.messaging.Source
  13  *
  14  * Esta definicion custom se usaría igual que Sink y Source :)
  15  * Donde veas Sink y Source podrías haber puesto esto en su lugar ;)
  16  */
  17 public interface InputOutputChannels {
  18
  19   @Input("inputChannel")
  20   SubscribableChannel input();
  21
  22   @Output("outputChannel")
  23   MessageChannel output();
  24
  25 }