Broadcast Listener for rabbitmq

gistfile1.java

@Component("broadcastQueueConsumer")
public class BroadcastListener implements MessageListener{

  private final static Logger logger = Logger.getLogger(BroadcastListener.class.getName());
	
	@Autowired
	private SimpleMessageConverter messageAdapter ;
	
	@Autowired
	private BroadcastService broadcastService; 
	
	@Override
	public void onMessage(Message message) {
		
		try {
			String convertedMessage  = (String) messageAdapter.fromMessage(message);
			broadcastService.broadcast(convertedMessage); 
		} catch (Exception e) {
			logger.warning("Unable to read message  (err: "+e+")"); 
		} 
	}

}