44 lines
1.1 KiB
Java
44 lines
1.1 KiB
Java
|
package com.qxcm.moduleutil.bean;
|
|||
|
|
|
|||
|
|
import org.greenrobot.eventbus.EventBus;
|
|||
|
|
|
|||
|
|
import java.util.Map;
|
|||
|
|
|
|||
|
|
public class RoomMessageManager {
|
|||
|
|
|
|||
|
|
private static final RoomMessageManager instance = new RoomMessageManager();
|
|||
|
|
|
|||
|
|
private RoomMessageManager() {}
|
|||
|
|
|
|||
|
|
public static RoomMessageManager getInstance() {
|
|||
|
|
return instance;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 接收原始消息，转换后发送到 EventBus
|
|||
|
|
*/
|
|||
|
|
public void onNewMessage(String roomId, int msgType, RoomMessageEvent.T data) {
|
|||
|
|
RoomMessageEvent event = new RoomMessageEvent(msgType, roomId, data);
|
|||
|
|
EventBus.getDefault().post(event);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 注册监听器（如 Fragment 或 Activity）
|
|||
|
|
*/
|
|||
|
|
public void register(Object subscriber) {
|
|||
|
|
if (!EventBus.getDefault().isRegistered(subscriber)) {
|
|||
|
|
EventBus.getDefault().register(subscriber);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 反注册监听器
|
|||
|
|
*/
|
|||
|
|
public void unregister(Object subscriber) {
|
|||
|
|
if (EventBus.getDefault().isRegistered(subscriber)) {
|
|||
|
|
EventBus.getDefault().unregister(subscriber);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|