Business
Jobs
  • About Us
  • Solutions
    • Job Postings
      Post your job and receive qualified candidates in 48h.
    • Candidate Assessments
      500+ technical and psychological tests, plus anti-fraud.
    • Headhunting
      Tailor-made executive search from start to finish.
    • Payroll + EOR
      Payroll dispersal and EOR across 15+ LATAM countries.
  • Pricing
  • Jobs

0

137
Views
How to Consume Message in Spring Cloud Stream Functional Binding

I am new to Functional Binding. Previously, I was doing my producer and consumer transactions with the annotation approach as follows. I could not understand how to do the same operations using functional binding. Can someone explain to me? Please do not share links. I would appreciate it if you could show me an example, even if it is a small one.

Producer

```

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());

}

```

ProducerStream.java

```

String OUTPUT = "dataOutput";

@Output(ProducerStream.OUTPUT)

MessageChannel outputChannel();

```

Listener

```

@StreamListener(ListenerStream.INPUT_DATA)

@Override

public void listenData(Data data) {

processService.processData(data);

}

```

ListenerStream.java

```

String INPUT_DATA = "dataInput";

@Input(INPUT_DATA)

SubscribableChannel inputChannel();

```

application.yml

spring:

application:

cloud:

bindings:

dataOutput:

destination: data-topic

dataInput:

destination: data-topic

about 4 years ago · Neslihan Kolukısa
Answer question
Find remote jobs

Discover the new way to find a job!

Top jobs
Top job categories
Business
Post vacancy Pricing Sales
Legal
Terms and conditions Privacy policy
© 2026 PeakU Inc. All Rights Reserved.
Andres GPT
Show me some job opportunities
There's an error!