Soy nuevo en enlace funcional. Anteriormente, estaba haciendo mis transacciones de productor y consumidor con el enfoque de anotación de la siguiente manera. No pude entender cómo hacer las mismas operaciones usando el enlace funcional. ¿Alguien puede explicarme? Por favor, no comparta enlaces. Le agradecería que me mostrara un ejemplo, aunque sea pequeño.
Productor
```
private final MessageChannel outputChannel;
public ProducerImpl(@Qualifier(ProducerStream.OUTPUT) MessageChannel outputChannel) {
this.outputChannel = outputChannel;
this.genericSettings = genericSettings;
}
@Override
public void publishData(Data data) {
outputChannel.send(MessageBuilder.withPayload(data).build());
}
```
```
String OUTPUT = "dataOutput";
@Output(ProducerStream.OUTPUT)
MessageChannel outputChannel();
```
Oyente
```
@StreamListener(ListenerStream.INPUT_DATA)
@Override
public void listenData(Data data) {
processService.processData(data);
}
```
```
String INPUT_DATA = "dataInput";
@Input(INPUT_DATA)
SubscribableChannel inputChannel();
```
aplicación.yml
spring:
application:
cloud:
bindings:
dataOutput:
destination: data-topic
dataInput:
destination: data-topic