| | |
| | | * 注册监听
|
| | | */
|
| | | void registerListener() {
|
| | | if (!TextUtils.isEmpty(observeTopic)) {
|
| | | if (listener != null && !TextUtils.isEmpty(observeTopic)) {
|
| | | EventDispatcher.getInstance().register(observeTopic, eventListener);
|
| | | // LogUtils.i("HdlSocketHelper", "register event");
|
| | | }
|
| | |
| | | }
|
| | | }
|
| | | } catch (Exception e) {
|
| | | e.printStackTrace();
|
| | | LogUtils.e("发送数据失败:" + e.getMessage());
|
| | | }
|
| | | } else {
|
| | | //超出重发次数并没有收到回复
|
| | |
| | | private void notifyFailure() {
|
| | | //移除监听
|
| | | removeListener();
|
| | | if (sendThread != null) {
|
| | | sendThread.shutdownNow();
|
| | | sendThread = null;
|
| | | }
|
| | | if (listener != null) {
|
| | | listener.onFailure();
|
| | | listener = null;
|
| | | try {
|
| | | if (sendThread != null) {
|
| | | sendThread.shutdownNow();
|
| | | sendThread = null;
|
| | | }
|
| | | if (listener != null) {
|
| | | listener.onFailure();
|
| | | listener = null;
|
| | | }
|
| | | } catch (Exception e) {
|
| | |
|
| | | }
|
| | | }
|
| | | }
|