docs: @Override
  	public void onMessage(String channel, String message) {
  		QueueBean queueBean = SerializeImpl.getInstance().toObject(message, QueueBean.class);
  
  		boolean isMySelf = this.sender.equals(queueBean.getSender());
  		// if (!listenOneSelf) {
  		// if (this.sender.equals(queueBean.getSender())) {
  		// // 忽略自己发送的消息.
  		// // logger.info("忽略自己发送的消息:" + channel + "=" + message);
  		// return;
  		// }
  		// }
  		this.memdbRsyncQueue.add(queueBean.getType(), queueBean.getKey(), queueBean.getValue(), isMySelf);
  		// System.out.println(channel + "=" + message);
  	}