[rocketmq] branch develop updated: #ROCKETMQ-340# improve code for avoid ClassCastException. (#210)

[vongosling]

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 <fuyou...@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);
         }