// initialize object with hostname.
ReactiveListener reactiveListener = new ReactiveListener("localhost");

// set queuename you want to subscribe
reactiveListener.setQueue("messageQueue");

// setCallBackClass which implements `ListenerInterface` interface
reactiveListener.setCallBackMethod(test);

// subscribe start
reactiveListener.listen();

public class Test implements ListenerInterface {

    private String name;

    Test(String name){
        this.name = name;
    }

    // callback method that is called when subsribing a message.
    @Override
    public void callBack(Message message) {
        System.out.println("receiveMessage::"+message.toString());
    }

    // callback method that is called when error happend by subscribing.
    @Override
    public void errorCallBack(Throwable throwable) {
        System.out.println("error::"+throwable.getMessage());
    }
}

reactiveListener.stop();

// set messageConverter
reactiveListener.setMessageConverter(messageConverter);


// default messageConverter is this .
private Jackson2JsonMessageConverter defaultMessageConverter(){
        ObjectMapper objectMapper = Jackson2ObjectMapperBuilder.json()
                .modules(new JavaTimeModule())
                .dateFormat(new StdDateFormat())
                .build();
        Jackson2JsonMessageConverter jackson2JsonMessageConverter
                = new Jackson2JsonMessageConverter(objectMapper);
        return jackson2JsonMessageConverter;
}