消息队列IMMQ_QUEUE_APP2WEB = "burnAfterReading"

爱你爱自己 · 2 年前

public abstract class BurnAfterReadingProcessor extends MQProvider
{
private static Logger logger = LoggerFactory.getLogger(BurnAfterReadingProcessor.class);

/** 收到消息的字符解码格式。默认utf-8。 */
public final static String IMMQ_DECODE_CHARSET = "UTF-8";

/** 消息队列服务器连接URI，形如：“amqp://admin:123456789@192.168.1.190” */
public static String IMMQ_URI = BaseConf.getInstance().getIM_BRIDGE_MQ_URI();
/** 消息中转队列：Web端IM转发至APP端的消息，本类是此队列的消费者，表示从Web端读取消息 */
public static String IMMQ_QUEUE_WEB2APP = "q_web2app";
/** 消息中转队列：APP端IM转发至Web端的消息，本类是此队列的生产者，表示将消息发送至Web端 */
public static String IMMQ_QUEUE_APP2WEB = "burnAfterReading";

public BurnAfterReadingProcessor()
{
super(IMMQ_URI, IMMQ_QUEUE_APP2WEB, IMMQ_QUEUE_WEB2APP, "IMMQ", false);
}IMMQ_QUEUE_APP2WEB = "burnAfterReading" burnAfterReading是干什么的，这个应该是q_app2web队列吧