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