Consumer - Anar-Framework/anar-lib-activemq GitHub Wiki

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
    }

}