Repository navigation

Consumer

Jump to bottom

Mohammad Badar Hashimi edited this page Jan 19, 2020 · 2 revisions

Implements AnarConsumer interface and override consume method

public class MyConsumer implements AnarConsumer {

    @JmsListener(destination = myTopic, containerFactory = "defaultJmsListenerContainerFactory")
    public void consume(MyClass obj) {
       // business logic comes here
    }

}