[ROCKETMQ-138] Remove hard coded Aliyun authentication code, closes apache/incubator-rocketmq#75
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/3d35eed1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/3d35eed1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/3d35eed1 Branch: refs/heads/master Commit: 3d35eed1a388a8e4d43e1f9034d62895d8fd7d9e Parents: 8c793c0 Author: Jaskey <[email protected]> Authored: Tue Apr 11 14:38:05 2017 +0800 Committer: dongeforever <[email protected]> Committed: Tue Jun 6 11:37:29 2017 +0800 ---------------------------------------------------------------------- .../apache/rocketmq/remoting/netty/NettyRemotingAbstract.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3d35eed1/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java ---------------------------------------------------------------------- diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java index 08b51db..83eeb02 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java @@ -126,11 +126,8 @@ public abstract class NettyRemotingAbstract { } } } catch (Throwable e) { - if (!"com.aliyun.openservices.ons.api.impl.authority.exception.AuthenticationException" - .equals(e.getClass().getCanonicalName())) { - PLOG.error("process request exception", e); - PLOG.error(cmd.toString()); - } + PLOG.error("process request exception", e); + PLOG.error(cmd.toString()); if (!cmd.isOnewayRPC()) { final RemotingCommand response = RemotingCommand.createResponseCommand(RemotingSysResponseCode.SYSTEM_ERROR, //
