public abstract class BridgeProcessor extends MQProvider
限定符和类型 | 字段和说明 |
---|---|
static java.lang.String |
IMMQ_DECODE_CHARSET
收到消息的字符解码格式。
|
static java.lang.String |
IMMQ_QUEUE_APP2WEB
消息中转队列:APP端IM转发至Web端的消息,本类是此队列的生产者,表示将消息发送至Web端
|
static java.lang.String |
IMMQ_QUEUE_WEB2APP
消息中转队列:Web端IM转发至APP端的消息,本类是此队列的消费者,表示从Web端读取消息
|
static java.lang.String |
IMMQ_URI
消息队列服务器连接URI,形如:“amqp://admin:123456789@192.168.1.190”
|
_connection, _factory, _pubChannel, _workerChannel, consumerObserver, consumFromQueue, decodeCharset, DEFAULT_DECODE_CHARSET, DEFAULT_ENCODE_CHARSET, encodeCharset, mqURI, publishToQueue, publishTrayAgainCache, publishTrayAgainEnable, retryWorkerRunning, startRunning, TAG, timerForRetryWorker, timerForStartAgain
构造器和说明 |
---|
BridgeProcessor() |
限定符和类型 | 方法和说明 |
---|---|
protected abstract boolean |
offlineC2CProcessCallback(Protocal p)
无法在线实时发送成功的消息将通过本回调方法进行处理。
|
protected abstract void |
realtimeC2CSuccessCallback(Protocal p)
在线实时将消息桥接转发成功后被调用的回调方法。
|
protected boolean |
work(byte[] contentBody)
处理通过MQ中间件收到的桥接消息。
|
init, publish, publish, start, startPublisher, startWorker, tryGetConnection, whenConnected
public static final java.lang.String IMMQ_DECODE_CHARSET
public static java.lang.String IMMQ_URI
public static java.lang.String IMMQ_QUEUE_WEB2APP
public static java.lang.String IMMQ_QUEUE_APP2WEB
protected boolean work(byte[] contentBody)
work
在类中 MQProvider
contentBody
- 从MQ服务器取到的消息内容byte数组protected abstract void realtimeC2CSuccessCallback(Protocal p)
p
- 本次桥接转发的消息包protected abstract boolean offlineC2CProcessCallback(Protocal p)
p
- 本次桥接转发的消息包