| | |
| | |
|
| | | /**
|
| | | * 两个主题是否匹配
|
| | | *
|
| | | * @param desString 字典中的主题
|
| | | * @param sourceString 接收到的主题
|
| | | * @return
|
| | |
| | |
|
| | | /**
|
| | | * 事件分发器,分发所有在接口列表中的事件
|
| | | *
|
| | | * @param topicTag -
|
| | | * @param o -
|
| | | */
|
| | |
| | | public synchronized void filePost() {
|
| | | //TODO
|
| | | }
|
| | |
|
| | | /**
|
| | | * 注册所有主题消息的监听
|
| | | *
|
| | | * @param listener
|
| | | */
|
| | | public synchronized void registerAllTopicsListener(EventListener listener) {
|
| | |
| | |
|
| | | /**
|
| | | * 取消所有主题消息的监听
|
| | | *
|
| | | * @param listener
|
| | | */
|
| | | public synchronized void removeAllTopicsListener(EventListener listener) {
|
| | |
| | | });
|
| | | }
|
| | |
|
| | | public synchronized void clear() {
|
| | | private synchronized void clear() {
|
| | | ALL_TOPICS_EVENT.clear();
|
| | | EVENT.clear();
|
| | | // TYPE.clear();
|
| | | }
|
| | |
|
| | | public synchronized void release() {
|
| | | private synchronized void release() {
|
| | | clear();
|
| | | ioThread.shutdownNow();
|
| | | }
|