You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2018/07/14 03:04:03 UTC
[rocketmq] branch develop updated: #ROCKETMQ-340# improve code for
avoid ClassCastException. (#210)
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 17648c6 #ROCKETMQ-340# improve code for avoid ClassCastException. (#210)
17648c6 is described below
commit 17648c67c3ca3f464ac34fe2207abd595ec1cd43
Author: fuyou001 <fu...@gmail.com>
AuthorDate: Sat Jul 14 11:03:59 2018 +0800
#ROCKETMQ-340# improve code for avoid ClassCastException. (#210)
---
.../java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
index a5967a0..0159d32 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
@@ -44,8 +44,10 @@ public class BrokerFastFailure {
public static RequestTask castRunnable(final Runnable runnable) {
try {
- FutureTaskExt object = (FutureTaskExt) runnable;
- return (RequestTask) object.getRunnable();
+ if (runnable instanceof FutureTaskExt) {
+ FutureTaskExt object = (FutureTaskExt) runnable;
+ return (RequestTask) object.getRunnable();
+ }
} catch (Throwable e) {
log.error(String.format("castRunnable exception, %s", runnable.getClass().getName()), e);
}