package com.gxx.dubbo.client.biz.impl; import org.apache.log4j.Logger; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageListener; import org.springframework.stereotype.Service; /** * topic模式(模糊匹配)queue监听者 * @author Gxx */ @Service(value = "serverToClientTopicListener2") public class ServerToClientTopicListener2 implements MessageListener { /** * 日志处理器 */ private final Logger logger = Logger.getLogger(ServerToClientTopicListener2.class); @Override public void onMessage(Message message) { logger.info("topic模式(模糊匹配)queue监听者[2]收到MQ内容:" + message); } }