Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
小五666\n哈哈
Rocketmq
提交
9ad9ad06
R
Rocketmq
项目概览
小五666\n哈哈
/
Rocketmq
与 Fork 源项目一致
Fork自
Apache RocketMQ / Rocketmq
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
R
Rocketmq
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
提交
9ad9ad06
编写于
7月 05, 2017
作者:
Y
yukon
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[ROCKETMQ-238] Catch Throwable to avoid error cancel some key scheduled tasks.
上级
b70b6800
变更
6
隐藏空白更改
内联
并排
Showing
6 changed file
with
9 addition
and
9 deletion
+9
-9
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
...ain/java/org/apache/rocketmq/broker/BrokerController.java
+2
-2
broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
...che/rocketmq/broker/client/ClientHousekeepingService.java
+2
-2
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
...g/apache/rocketmq/remoting/netty/NettyRemotingClient.java
+1
-1
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
...g/apache/rocketmq/remoting/netty/NettyRemotingServer.java
+1
-1
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
...n/java/org/apache/rocketmq/store/DefaultMessageStore.java
+2
-2
store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
...pache/rocketmq/store/schedule/ScheduleMessageService.java
+1
-1
未找到文件。
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
浏览文件 @
9ad9ad06
...
@@ -296,7 +296,7 @@ public class BrokerController {
...
@@ -296,7 +296,7 @@ public class BrokerController {
public
void
run
()
{
public
void
run
()
{
try
{
try
{
BrokerController
.
this
.
protectBroker
();
BrokerController
.
this
.
protectBroker
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
log
.
error
(
"protectBroker error."
,
e
);
log
.
error
(
"protectBroker error."
,
e
);
}
}
}
}
...
@@ -307,7 +307,7 @@ public class BrokerController {
...
@@ -307,7 +307,7 @@ public class BrokerController {
public
void
run
()
{
public
void
run
()
{
try
{
try
{
BrokerController
.
this
.
printWaterMark
();
BrokerController
.
this
.
printWaterMark
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
log
.
error
(
"printWaterMark error."
,
e
);
log
.
error
(
"printWaterMark error."
,
e
);
}
}
}
}
...
...
broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
浏览文件 @
9ad9ad06
...
@@ -45,8 +45,8 @@ public class ClientHousekeepingService implements ChannelEventListener {
...
@@ -45,8 +45,8 @@ public class ClientHousekeepingService implements ChannelEventListener {
public
void
run
()
{
public
void
run
()
{
try
{
try
{
ClientHousekeepingService
.
this
.
scanExceptionChannel
();
ClientHousekeepingService
.
this
.
scanExceptionChannel
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
log
.
error
(
""
,
e
);
log
.
error
(
"
Error occurred when scan not active client channels.
"
,
e
);
}
}
}
}
},
1000
*
10
,
1000
*
10
,
TimeUnit
.
MILLISECONDS
);
},
1000
*
10
,
1000
*
10
,
TimeUnit
.
MILLISECONDS
);
...
...
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
浏览文件 @
9ad9ad06
...
@@ -166,7 +166,7 @@ public class NettyRemotingClient extends NettyRemotingAbstract implements Remoti
...
@@ -166,7 +166,7 @@ public class NettyRemotingClient extends NettyRemotingAbstract implements Remoti
public
void
run
()
{
public
void
run
()
{
try
{
try
{
NettyRemotingClient
.
this
.
scanResponseTable
();
NettyRemotingClient
.
this
.
scanResponseTable
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
log
.
error
(
"scanResponseTable exception"
,
e
);
log
.
error
(
"scanResponseTable exception"
,
e
);
}
}
}
}
...
...
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
浏览文件 @
9ad9ad06
...
@@ -195,7 +195,7 @@ public class NettyRemotingServer extends NettyRemotingAbstract implements Remoti
...
@@ -195,7 +195,7 @@ public class NettyRemotingServer extends NettyRemotingAbstract implements Remoti
public
void
run
()
{
public
void
run
()
{
try
{
try
{
NettyRemotingServer
.
this
.
scanResponseTable
();
NettyRemotingServer
.
this
.
scanResponseTable
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
log
.
error
(
"scanResponseTable exception"
,
e
);
log
.
error
(
"scanResponseTable exception"
,
e
);
}
}
}
}
...
...
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
浏览文件 @
9ad9ad06
...
@@ -1443,7 +1443,7 @@ public class DefaultMessageStore implements MessageStore {
...
@@ -1443,7 +1443,7 @@ public class DefaultMessageStore implements MessageStore {
this
.
deleteExpiredFiles
();
this
.
deleteExpiredFiles
();
this
.
redeleteHangedFile
();
this
.
redeleteHangedFile
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
DefaultMessageStore
.
log
.
warn
(
this
.
getServiceName
()
+
" service has exception. "
,
e
);
DefaultMessageStore
.
log
.
warn
(
this
.
getServiceName
()
+
" service has exception. "
,
e
);
}
}
}
}
...
@@ -1583,7 +1583,7 @@ public class DefaultMessageStore implements MessageStore {
...
@@ -1583,7 +1583,7 @@ public class DefaultMessageStore implements MessageStore {
public
void
run
()
{
public
void
run
()
{
try
{
try
{
this
.
deleteExpiredFiles
();
this
.
deleteExpiredFiles
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
DefaultMessageStore
.
log
.
warn
(
this
.
getServiceName
()
+
" service has exception. "
,
e
);
DefaultMessageStore
.
log
.
warn
(
this
.
getServiceName
()
+
" service has exception. "
,
e
);
}
}
}
}
...
...
store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
浏览文件 @
9ad9ad06
...
@@ -121,7 +121,7 @@ public class ScheduleMessageService extends ConfigManager {
...
@@ -121,7 +121,7 @@ public class ScheduleMessageService extends ConfigManager {
public
void
run
()
{
public
void
run
()
{
try
{
try
{
ScheduleMessageService
.
this
.
persist
();
ScheduleMessageService
.
this
.
persist
();
}
catch
(
Exception
e
)
{
}
catch
(
Throwable
e
)
{
log
.
error
(
"scheduleAtFixedRate flush exception"
,
e
);
log
.
error
(
"scheduleAtFixedRate flush exception"
,
e
);
}
}
}
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录