class JmsMessageListener implements MessageListener {

	@Override
	public void onMessage(Message msg) {
		logger.debug("received new message from queue '{}'", queue);
		String text = Exceptions.sneak().get(() -> extractTextFromMessage(msg));
		SimpleMessage message = new SimpleMessage(text, queue, getMessageProperties(msg));
		storage.addMessage(message);
	}

	public  JmsMessageListener(String queue, LocalMessageStorage storage, List<String> propertiesToExtract,
			String encoding);

}