ConsumerConfig.java

    @Bean
    public SimpleMessageListenerContainer listenerContainer() {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory());
        container.setQueueNames(this.employeeQueueName);
        container.setMessageListener(new MessageListenerAdapter(new MessageHandler(), jsonMessageConverter()));
        return container;
    }