Repository: incubator-rocketmq
Updated Branches:
refs/heads/develop 45a64fd6a -> a8fa05e8c
[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/a8fa05e8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/a8fa05e8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/a8fa05e8
Branch: refs/heads/develop
Commit: a8fa05e8c0b0e57b6e2278747a5f6a8111447a8e
Parents: 45a64fd
Author: Jaskey <linjunjie1103@gmail.com>
Authored: Tue Apr 11 14:38:05 2017 +0800
Committer: yukon <yukon@apache.org>
Committed: Tue Apr 11 14:38:05 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/a8fa05e8/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,
//
|