SO Post http://stackoverflow.com/questions/41056418

MyRedisMessageSubscriber.java

public class MyRedisMessageSubscriber extends RedisMessageSubscriber {

	static final Action2<Message, byte[]> ACTION = new Action2<Message, byte[]>() {
		
		ObjectMapper objectMapper = new ObjectMapper();
		
		@Override
		public void call(Message message, byte[] bytes) {

			
			try {
				String result = objectMapper.readValue(message.getBody(), String.class);
				logger.info("received：" + result);
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	};

	public MyRedisMessageSubscriber() {
		super(ACTION);
	}
}

RedisMessageSubscriber.java

public abstract class RedisMessageSubscriber implements MessageListener {

	protected static Logger logger = LogManager.getLogger(RedisMessageSubscriber.class);

	// action inspect here
	private final Action2<Message, byte[]> action;

	public RedisMessageSubscriber(Action2<Message, byte[]> action) {
		this.action = action;
	}

	@Override
	public void onMessage(Message message, byte[] bytes) {

		logger.info("===> redis subscribe message in <===");

		action.call(message, bytes);
	}
}