Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
oceanbase
oblogclient
比较版本
7d93664d23d975abe7e44c89e9cda97ca4a3399d...3f5306d36967dee1a1b31324a5d42d918f2d9482
O
oblogclient
项目概览
oceanbase
/
oblogclient
大约 1 年 前同步成功
通知
4
Star
14
Fork
11
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
O
oblogclient
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
源分支
3f5306d36967dee1a1b31324a5d42d918f2d9482
选择Git版本
...
目标分支
7d93664d23d975abe7e44c89e9cda97ca4a3399d
选择Git版本
比较
Commits (5)
https://gitcode.net/oceanbase/oblogclient/-/commit/1a92566f92171dcf06d4c03dc467912d82f2e69d
update checkpoint for record queue (#40)
2022-05-19T12:13:28+08:00
He Wang
wanghechn@qq.com
https://gitcode.net/oceanbase/oblogclient/-/commit/aa5a07830cddb306a49aee66f02af579148f3313
format logger message (#39)
2022-05-19T18:29:11+08:00
He Wang
wanghechn@qq.com
* format logger message * revert logic change
https://gitcode.net/oceanbase/oblogclient/-/commit/eb199f78ec74875e83fe584ce77e218686351df1
fix & optimize ClientStream process (#37)
2022-05-20T10:50:42+08:00
He Wang
wanghechn@qq.com
* optimize process thread * revert checkpoint update
https://gitcode.net/oceanbase/oblogclient/-/commit/64e458601835bc034aff891d81d42d38491a78a1
[maven-release-plugin] prepare release logclient-1.0.4
2022-05-20T11:28:03+08:00
He Wang
wanghechn@qq.com
https://gitcode.net/oceanbase/oblogclient/-/commit/3f5306d36967dee1a1b31324a5d42d918f2d9482
[maven-release-plugin] prepare for next development iteration
2022-05-20T11:28:12+08:00
He Wang
wanghechn@qq.com
隐藏空白更改
内联
并排
Showing
9 changed file
with
58 addition
and
62 deletion
+58
-62
common/pom.xml
common/pom.xml
+1
-1
common/src/main/java/com/oceanbase/oms/logmessage/LogMessage.java
...rc/main/java/com/oceanbase/oms/logmessage/LogMessage.java
+2
-2
logproxy-client/pom.xml
logproxy-client/pom.xml
+1
-1
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/config/ObReaderConfig.java
...com/oceanbase/clogproxy/client/config/ObReaderConfig.java
+5
-1
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientHandler.java
.../oceanbase/clogproxy/client/connection/ClientHandler.java
+10
-9
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientStream.java
...m/oceanbase/clogproxy/client/connection/ClientStream.java
+32
-35
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/Connection.java
...com/oceanbase/clogproxy/client/connection/Connection.java
+4
-4
logproxy-client/src/test/java/com/oceanbase/clogproxy/client/LogProxyClientTest.java
...va/com/oceanbase/clogproxy/client/LogProxyClientTest.java
+2
-8
pom.xml
pom.xml
+1
-1
未找到文件。
common/pom.xml
浏览文件 @
3f5306d3
...
@@ -16,7 +16,7 @@ See the Mulan PSL v2 for more details.
...
@@ -16,7 +16,7 @@ See the Mulan PSL v2 for more details.
<parent>
<parent>
<groupId>
com.oceanbase.logclient
</groupId>
<groupId>
com.oceanbase.logclient
</groupId>
<artifactId>
logclient
</artifactId>
<artifactId>
logclient
</artifactId>
<version>
1.0.
4
-SNAPSHOT
</version>
<version>
1.0.
5
-SNAPSHOT
</version>
<relativePath>
../pom.xml
</relativePath>
<relativePath>
../pom.xml
</relativePath>
</parent>
</parent>
...
...
common/src/main/java/com/oceanbase/oms/logmessage/LogMessage.java
浏览文件 @
3f5306d3
...
@@ -941,7 +941,7 @@ public class LogMessage extends DataMessage.Record {
...
@@ -941,7 +941,7 @@ public class LogMessage extends DataMessage.Record {
}
}
int
j
=
keyStr
.
indexOf
(
')'
,
i
);
int
j
=
keyStr
.
indexOf
(
')'
,
i
);
if
(
j
==
-
1
)
{
if
(
j
==
-
1
)
{
log
.
error
(
"
p
arse key error"
);
log
.
error
(
"
P
arse key error"
);
return
null
;
return
null
;
}
}
m
=
j
;
m
=
j
;
...
@@ -1077,7 +1077,7 @@ public class LogMessage extends DataMessage.Record {
...
@@ -1077,7 +1077,7 @@ public class LogMessage extends DataMessage.Record {
}
}
return
primaryValues
;
return
primaryValues
;
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
throw
new
RuntimeException
(
e
);
throw
new
LogMessageException
(
e
.
getMessage
(),
e
.
getCause
()
);
}
}
}
}
...
...
logproxy-client/pom.xml
浏览文件 @
3f5306d3
...
@@ -16,7 +16,7 @@ See the Mulan PSL v2 for more details.
...
@@ -16,7 +16,7 @@ See the Mulan PSL v2 for more details.
<parent>
<parent>
<groupId>
com.oceanbase.logclient
</groupId>
<groupId>
com.oceanbase.logclient
</groupId>
<artifactId>
logclient
</artifactId>
<artifactId>
logclient
</artifactId>
<version>
1.0.
4
-SNAPSHOT
</version>
<version>
1.0.
5
-SNAPSHOT
</version>
<relativePath>
../pom.xml
</relativePath>
<relativePath>
../pom.xml
</relativePath>
</parent>
</parent>
...
...
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/config/ObReaderConfig.java
浏览文件 @
3f5306d3
...
@@ -132,8 +132,12 @@ public class ObReaderConfig extends AbstractConnectionConfig {
...
@@ -132,8 +132,12 @@ public class ObReaderConfig extends AbstractConnectionConfig {
+
", cluster_password=******, "
+
", cluster_password=******, "
+
"tb_white_list="
+
"tb_white_list="
+
TABLE_WHITE_LIST
+
TABLE_WHITE_LIST
+
", tb_black_list="
+
TABLE_BLACK_LIST
+
", start_timestamp="
+
", start_timestamp="
+
START_TIMESTAMP
;
+
START_TIMESTAMP
+
", timezone="
+
TIME_ZONE
;
}
}
/**
/**
...
...
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientHandler.java
浏览文件 @
3f5306d3
...
@@ -226,7 +226,7 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
...
@@ -226,7 +226,7 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
byte
[]
bytes
=
new
byte
[
dataLength
];
byte
[]
bytes
=
new
byte
[
dataLength
];
buffer
.
readBytes
(
bytes
);
buffer
.
readBytes
(
bytes
);
LogProxyProto
.
RuntimeStatus
response
=
LogProxyProto
.
RuntimeStatus
.
parseFrom
(
bytes
);
LogProxyProto
.
RuntimeStatus
response
=
LogProxyProto
.
RuntimeStatus
.
parseFrom
(
bytes
);
logger
.
debug
(
"
s
erver status: {}"
,
response
.
toString
());
logger
.
debug
(
"
S
erver status: {}"
,
response
.
toString
());
state
=
HandshakeStateV1
.
PB_HEAD
;
state
=
HandshakeStateV1
.
PB_HEAD
;
}
else
{
}
else
{
dataNotEnough
=
true
;
dataNotEnough
=
true
;
...
@@ -252,18 +252,18 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
...
@@ -252,18 +252,18 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
*/
*/
private
void
checkHeader
(
int
version
,
int
type
,
int
length
)
{
private
void
checkHeader
(
int
version
,
int
type
,
int
length
)
{
if
(
ProtocolVersion
.
codeOf
(
version
)
==
null
)
{
if
(
ProtocolVersion
.
codeOf
(
version
)
==
null
)
{
logger
.
error
(
"
u
nsupported protocol version: {}"
,
version
);
logger
.
error
(
"
U
nsupported protocol version: {}"
,
version
);
throw
new
LogProxyClientException
(
throw
new
LogProxyClientException
(
ErrorCode
.
E_PROTOCOL
,
"
u
nsupported protocol version: "
+
version
);
ErrorCode
.
E_PROTOCOL
,
"
U
nsupported protocol version: "
+
version
);
}
}
if
(
HeaderType
.
codeOf
(
type
)
==
null
)
{
if
(
HeaderType
.
codeOf
(
type
)
==
null
)
{
logger
.
error
(
"
u
nsupported header type: {}"
,
type
);
logger
.
error
(
"
U
nsupported header type: {}"
,
type
);
throw
new
LogProxyClientException
(
throw
new
LogProxyClientException
(
ErrorCode
.
E_HEADER_TYPE
,
"
u
nsupported header type: "
+
type
);
ErrorCode
.
E_HEADER_TYPE
,
"
U
nsupported header type: "
+
type
);
}
}
if
(
length
<=
0
)
{
if
(
length
<=
0
)
{
logger
.
error
(
"
d
ata length equals 0"
);
logger
.
error
(
"
D
ata length equals 0"
);
throw
new
LogProxyClientException
(
ErrorCode
.
E_LEN
,
"
d
ata length equals 0"
);
throw
new
LogProxyClientException
(
ErrorCode
.
E_LEN
,
"
D
ata length equals 0"
);
}
}
}
}
...
@@ -334,6 +334,7 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
...
@@ -334,6 +334,7 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
while
(
true
)
{
while
(
true
)
{
try
{
try
{
recordQueue
.
put
(
new
StreamContext
.
TransferPacket
(
logMessage
));
recordQueue
.
put
(
new
StreamContext
.
TransferPacket
(
logMessage
));
stream
.
setCheckpointString
(
logMessage
.
getTimestamp
());
break
;
break
;
}
catch
(
InterruptedException
e
)
{
}
catch
(
InterruptedException
e
)
{
// do nothing
// do nothing
...
@@ -452,8 +453,8 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
...
@@ -452,8 +453,8 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
poolFlag
=
false
;
poolFlag
=
false
;
logger
.
info
(
logger
.
info
(
"C
onnect broken of ClientId: {} with
LogProxy: {}"
,
"C
hannel closed with ClientId: {},
LogProxy: {}"
,
params
.
info
(),
params
.
getClientId
(),
NetworkUtil
.
parseRemoteAddress
(
ctx
.
channel
()));
NetworkUtil
.
parseRemoteAddress
(
ctx
.
channel
()));
ctx
.
channel
().
disconnect
();
ctx
.
channel
().
disconnect
();
ctx
.
close
();
ctx
.
close
();
...
...
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/ClientStream.java
浏览文件 @
3f5306d3
...
@@ -32,11 +32,12 @@ public class ClientStream {
...
@@ -32,11 +32,12 @@ public class ClientStream {
/** Flag of whether the stream is started. */
/** Flag of whether the stream is started. */
private
final
AtomicBoolean
started
=
new
AtomicBoolean
(
false
);
private
final
AtomicBoolean
started
=
new
AtomicBoolean
(
false
);
/** The process thread. */
/** The process thread. */
private
Thread
thread
=
null
;
private
Thread
thread
=
null
;
/** Context of stream. */
/** Context of stream. */
private
StreamContext
context
;
private
final
StreamContext
context
;
/** Checkpoint string used to resume writing into the queue. */
/** Checkpoint string used to resume writing into the queue. */
private
String
checkpointString
;
private
String
checkpointString
;
...
@@ -79,10 +80,10 @@ public class ClientStream {
...
@@ -79,10 +80,10 @@ public class ClientStream {
this
.
context
=
new
StreamContext
(
this
,
clientConf
,
connectionParams
);
this
.
context
=
new
StreamContext
(
this
,
clientConf
,
connectionParams
);
}
}
/** Close
and wait the connection
. */
/** Close
the connection and wait the process thread
. */
public
void
stop
()
{
public
void
stop
()
{
if
(
!
started
.
compareAndSet
(
true
,
false
))
{
if
(
started
.
compareAndSet
(
true
,
false
))
{
logger
.
info
(
"
stopping LogProxy Client....
"
);
logger
.
info
(
"
Try to stop this client
"
);
if
(
connection
!=
null
)
{
if
(
connection
!=
null
)
{
connection
.
close
();
connection
.
close
();
...
@@ -91,8 +92,8 @@ public class ClientStream {
...
@@ -91,8 +92,8 @@ public class ClientStream {
join
();
join
();
thread
=
null
;
thread
=
null
;
logger
.
info
(
"Client stopped successfully"
);
}
}
logger
.
info
(
"stopped LogProxy Client"
);
}
}
/** Call {@link Thread#join()} method of process thread. */
/** Call {@link Thread#join()} method of process thread. */
...
@@ -101,8 +102,8 @@ public class ClientStream {
...
@@ -101,8 +102,8 @@ public class ClientStream {
try
{
try
{
thread
.
join
();
thread
.
join
();
}
catch
(
InterruptedException
e
)
{
}
catch
(
InterruptedException
e
)
{
logger
.
warn
(
"
ClientStream thread is interrupted: "
+
e
.
getMessage
());
logger
.
warn
(
"
Waits for process thread failed : {}"
,
e
.
getMessage
());
s
top
();
triggerS
top
();
}
}
}
}
}
}
...
@@ -140,11 +141,10 @@ public class ClientStream {
...
@@ -140,11 +141,10 @@ public class ClientStream {
while
(
isRunning
())
{
while
(
isRunning
())
{
ReconnectState
state
=
reconnect
();
ReconnectState
state
=
reconnect
();
if
(
state
==
ReconnectState
.
EXIT
)
{
if
(
state
==
ReconnectState
.
EXIT
)
{
logger
.
error
(
"read thread to exit"
);
triggerException
(
triggerException
(
new
LogProxyClientException
(
new
LogProxyClientException
(
ErrorCode
.
E_MAX_RECONNECT
,
ErrorCode
.
E_MAX_RECONNECT
,
"
exceed max reconnect retry
"
));
"
Exceed max retry times
"
));
break
;
break
;
}
}
if
(
state
==
ReconnectState
.
RETRY
)
{
if
(
state
==
ReconnectState
.
RETRY
)
{
...
@@ -157,8 +157,8 @@ public class ClientStream {
...
@@ -157,8 +157,8 @@ public class ClientStream {
continue
;
continue
;
}
}
StreamContext
.
TransferPacket
packet
;
StreamContext
.
TransferPacket
packet
=
null
;
while
(
true
)
{
while
(
isRunning
()
)
{
try
{
try
{
packet
=
packet
=
context
.
recordQueue
()
context
.
recordQueue
()
...
@@ -193,33 +193,24 @@ public class ClientStream {
...
@@ -193,33 +193,24 @@ public class ClientStream {
+
packet
.
getType
());
+
packet
.
getType
());
}
}
}
catch
(
LogProxyClientException
e
)
{
}
catch
(
LogProxyClientException
e
)
{
triggerStop
();
triggerException
(
e
);
triggerException
(
e
);
return
;
break
;
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
// if exception occurred, we exit
triggerStop
();
triggerException
(
triggerException
(
new
LogProxyClientException
(
ErrorCode
.
E_USER
,
e
));
new
LogProxyClientException
(
ErrorCode
.
E_USER
,
e
));
return
;
break
;
}
}
}
}
started
.
set
(
false
);
triggerStop
();
if
(
connection
!=
null
)
{
logger
.
info
(
"Client process thread exit"
);
connection
.
close
();
}
thread
=
null
;
// TODO... if exception occurred, run handler callback
logger
.
warn
(
"!!! read thread exit !!!"
);
});
});
thread
.
setDaemon
(
false
);
thread
.
setDaemon
(
false
);
thread
.
start
();
thread
.
start
();
}
}
// add a shutdown hook to trigger the stop the process
Runtime
.
getRuntime
().
addShutdownHook
(
new
Thread
(
this
::
stop
));
}
}
/**
/**
...
@@ -239,15 +230,14 @@ public class ClientStream {
...
@@ -239,15 +230,14 @@ public class ClientStream {
private
ReconnectState
reconnect
()
{
private
ReconnectState
reconnect
()
{
// reconnect flag mark, tiny load for checking
// reconnect flag mark, tiny load for checking
if
(
reconnect
.
compareAndSet
(
true
,
false
))
{
if
(
reconnect
.
compareAndSet
(
true
,
false
))
{
logger
.
warn
(
"start to reconnect...
"
);
logger
.
info
(
"Try to reconnect
"
);
try
{
try
{
if
(
context
.
config
().
getMaxReconnectTimes
()
!=
-
1
if
(
context
.
config
().
getMaxReconnectTimes
()
!=
-
1
&&
retryTimes
>=
context
.
config
().
getMaxReconnectTimes
())
{
&&
retryTimes
>=
context
.
config
().
getMaxReconnectTimes
())
{
logger
.
error
(
logger
.
error
(
"
f
ailed to reconnect, exceed max reconnect retry time: {}"
,
"
F
ailed to reconnect, exceed max reconnect retry time: {}"
,
context
.
config
().
getMaxReconnectTimes
());
context
.
config
().
getMaxReconnectTimes
());
reconnect
.
set
(
true
);
return
ReconnectState
.
EXIT
;
return
ReconnectState
.
EXIT
;
}
}
...
@@ -261,32 +251,30 @@ public class ClientStream {
...
@@ -261,32 +251,30 @@ public class ClientStream {
logger
.
warn
(
"reconnect set checkpoint: {}"
,
checkpointString
);
logger
.
warn
(
"reconnect set checkpoint: {}"
,
checkpointString
);
context
.
params
().
updateCheckpoint
(
checkpointString
);
context
.
params
().
updateCheckpoint
(
checkpointString
);
}
}
connection
=
ConnectionFactory
.
instance
().
createConnection
(
context
);
connection
=
ConnectionFactory
.
instance
().
createConnection
(
context
);
if
(
connection
!=
null
)
{
if
(
connection
!=
null
)
{
logger
.
warn
(
"reconnect SUCC
"
);
logger
.
info
(
"Reconnect successfully
"
);
retryTimes
=
0
;
retryTimes
=
0
;
reconnect
.
compareAndSet
(
true
,
false
);
return
ReconnectState
.
SUCCESS
;
return
ReconnectState
.
SUCCESS
;
}
}
logger
.
error
(
logger
.
error
(
"
f
ailed to reconnect, retry count: {}, max: {}"
,
"
F
ailed to reconnect, retry count: {}, max: {}"
,
++
retryTimes
,
++
retryTimes
,
context
.
config
().
getMaxReconnectTimes
());
context
.
config
().
getMaxReconnectTimes
());
// not success, retry next time
// not success, retry next time
reconnect
.
set
(
true
);
reconnect
.
set
(
true
);
return
ReconnectState
.
RETRY
;
return
ReconnectState
.
RETRY
;
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
logger
.
error
(
logger
.
error
(
"
f
ailed to reconnect, retry count: {}, max: {}, message: {}"
,
"
F
ailed to reconnect, retry count: {}, max: {}, message: {}"
,
++
retryTimes
,
++
retryTimes
,
context
.
config
().
getMaxReconnectTimes
(),
context
.
config
().
getMaxReconnectTimes
(),
e
);
e
);
// not success, retry next time
// not success, retry next time
reconnect
.
set
(
true
);
reconnect
.
set
(
true
);
return
ReconnectState
.
RETRY
;
return
ReconnectState
.
RETRY
;
}
finally
{
}
finally
{
reconnecting
.
set
(
false
);
reconnecting
.
set
(
false
);
}
}
...
@@ -302,6 +290,15 @@ public class ClientStream {
...
@@ -302,6 +290,15 @@ public class ClientStream {
}
}
}
}
/**
* Set checkpoint string.
*
* @param checkpointString Checkpoint string.
*/
public
void
setCheckpointString
(
String
checkpointString
)
{
this
.
checkpointString
=
checkpointString
;
}
/**
/**
* Add a {@link RecordListener} to {@link #listeners}.
* Add a {@link RecordListener} to {@link #listeners}.
*
*
...
...
logproxy-client/src/main/java/com/oceanbase/clogproxy/client/connection/Connection.java
浏览文件 @
3f5306d3
...
@@ -41,7 +41,7 @@ public class Connection {
...
@@ -41,7 +41,7 @@ public class Connection {
/** Close this connection. */
/** Close this connection. */
public
void
close
()
{
public
void
close
()
{
if
(!
closed
.
compareAndSet
(
false
,
true
))
{
if
(!
closed
.
compareAndSet
(
false
,
true
))
{
logger
.
warn
(
"
c
onnection already closed"
);
logger
.
warn
(
"
C
onnection already closed"
);
}
}
if
(
channel
!=
null
)
{
if
(
channel
!=
null
)
{
if
(
channel
.
isActive
())
{
if
(
channel
.
isActive
())
{
...
@@ -49,7 +49,7 @@ public class Connection {
...
@@ -49,7 +49,7 @@ public class Connection {
channel
.
close
().
addListener
(
this
::
logCloseResult
).
syncUninterruptibly
();
channel
.
close
().
addListener
(
this
::
logCloseResult
).
syncUninterruptibly
();
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
logger
.
warn
(
logger
.
warn
(
"
c
lose connection to remote address {} exception"
,
"
C
lose connection to remote address {} exception"
,
NetworkUtil
.
parseRemoteAddress
(
channel
),
NetworkUtil
.
parseRemoteAddress
(
channel
),
e
);
e
);
}
}
...
@@ -68,12 +68,12 @@ public class Connection {
...
@@ -68,12 +68,12 @@ public class Connection {
if
(
future
.
isSuccess
())
{
if
(
future
.
isSuccess
())
{
if
(
logger
.
isInfoEnabled
())
{
if
(
logger
.
isInfoEnabled
())
{
logger
.
info
(
logger
.
info
(
"
c
lose connection to remote address {} success"
,
"
C
lose connection to remote address {} success"
,
NetworkUtil
.
parseRemoteAddress
(
channel
));
NetworkUtil
.
parseRemoteAddress
(
channel
));
}
}
}
else
{
}
else
{
logger
.
warn
(
logger
.
warn
(
"
c
lose connection to remote address {} fail"
,
"
C
lose connection to remote address {} fail"
,
NetworkUtil
.
parseRemoteAddress
(
channel
),
NetworkUtil
.
parseRemoteAddress
(
channel
),
future
.
cause
());
future
.
cause
());
}
}
...
...
logproxy-client/src/test/java/com/oceanbase/clogproxy/client/LogProxyClientTest.java
浏览文件 @
3f5306d3
...
@@ -50,10 +50,7 @@ public class LogProxyClientTest {
...
@@ -50,10 +50,7 @@ public class LogProxyClientTest {
@Override
@Override
public
void
onException
(
LogProxyClientException
e
)
{
public
void
onException
(
LogProxyClientException
e
)
{
if
(
e
.
needStop
())
{
logger
.
error
(
e
.
getMessage
());
logger
.
error
(
e
.
getMessage
());
client
.
stop
();
}
}
}
});
});
client
.
start
();
client
.
start
();
...
@@ -83,10 +80,7 @@ public class LogProxyClientTest {
...
@@ -83,10 +80,7 @@ public class LogProxyClientTest {
@Override
@Override
public
void
onException
(
LogProxyClientException
e
)
{
public
void
onException
(
LogProxyClientException
e
)
{
if
(
e
.
needStop
())
{
logger
.
error
(
e
.
getMessage
());
logger
.
error
(
e
.
getMessage
());
client
.
stop
();
}
}
}
});
});
client
.
start
();
client
.
start
();
...
...
pom.xml
浏览文件 @
3f5306d3
...
@@ -15,7 +15,7 @@ See the Mulan PSL v2 for more details.
...
@@ -15,7 +15,7 @@ See the Mulan PSL v2 for more details.
<groupId>
com.oceanbase.logclient
</groupId>
<groupId>
com.oceanbase.logclient
</groupId>
<artifactId>
logclient
</artifactId>
<artifactId>
logclient
</artifactId>
<version>
1.0.
4
-SNAPSHOT
</version>
<version>
1.0.
5
-SNAPSHOT
</version>
<packaging>
pom
</packaging>
<packaging>
pom
</packaging>
<name>
${project.groupId}:${project.artifactId}
</name>
<name>
${project.groupId}:${project.artifactId}
</name>
...
...