From b386de74c74a4431b2b735eb77c383b71b3ee5b2 Mon Sep 17 00:00:00 2001
From: 18034727885 <973609879@qq.com>
Date: 星期五, 31 七月 2026 14:50:06 +0800
Subject: [PATCH] 修复问题
---
rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java | 22 +++++++++++-----------
1 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java b/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java
index 49e3361..7ce2957 100644
--- a/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java
+++ b/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java
@@ -46,7 +46,7 @@
@Override
public void onCreate() {
super.onCreate();
- logRecord(TAG, "onCreate");
+ logRecord("onCreate");
}
void init() {
@@ -88,10 +88,10 @@
if (mConnection == null || mConnection.getChannel() == null
|| !mConnection.getChannel().isActive()
|| !mConnection.getChannel().isWritable()) {
- logRecord(TAG, "checkState need reConnect");
+ logRecord("checkState need reConnect");
return false;
} else {
- logRecord(TAG, "checkState no need reConnect");
+ logRecord("checkState no need reConnect");
return true;
}
}
@@ -121,7 +121,7 @@
@Override
public void onNetConnected(NetUtils.NetType type) {
super.onNetConnected(type);
- logRecord(TAG, "onNetConnected start checkState");
+ logRecord("onNetConnected start checkState");
boolean state = checkState();
if (!state) {
reConnect();
@@ -131,7 +131,7 @@
@Override
public void onNetDisConnect() {
super.onNetDisConnect();
- logRecord(TAG, "onNetDisConnect");
+ logRecord("onNetDisConnect");
}
};
NetStateReceiver.registerObserver(mNetChangeObserver);
@@ -187,7 +187,7 @@
public void onDestroy() {
super.onDestroy();
isDestroy = true;
- logRecord(TAG, "onDestroy");
+ logRecord("onDestroy");
NetStateReceiver.unRegisterNetworkStateReceiver(this);
if (subscriber != null && !subscriber.isUnsubscribed()) {
subscriber.unsubscribe();
@@ -202,7 +202,7 @@
private void connectServer() {
boolean status = NetUtils.isNetworkAvailable(this);
- logRecord(TAG, "connectServer net status = " + status);
+ logRecord("connectServer net status = " + status);
if (status) {
connectionSub();
connect(Config.SOCKET_SERVER, Config.SOCKET_PORT)
@@ -230,7 +230,7 @@
@Override
public void onError(Throwable e) {
e.printStackTrace();
- logRecord(TAG, "connectionSub onError " + e.getMessage());
+ logRecord("connectionSub onError " + e.getMessage());
reConnect();
}
@@ -261,7 +261,7 @@
@Override
public void onError(Throwable e) {
- logRecord(TAG, "initReceiveOb onError " + e.getMessage());
+ logRecord("initReceiveOb onError " + e.getMessage());
reConnect();
}
@@ -287,7 +287,7 @@
private void reConnect() {
- logRecord(TAG, "reConnect isDestroy = " + isDestroy);
+ logRecord("reConnect isDestroy = " + isDestroy);
if (isDestroy) {
return;
}
@@ -299,7 +299,7 @@
mConnection.close();
mConnection = null;
}
- logRecord(TAG, "reConnect sendHeart_websocket长连接断开，重新连接");
+ logRecord("reConnect sendHeart_websocket长连接断开，重新连接");
connectServer();
}
});
--
Gitblit v1.7.1