|
|
@@ -10,7 +10,11 @@ public class RpcRequestInfo {
|
|
|
private static ThreadLocal<RpcRequestInfo> rpcRequestInfo = new ThreadLocal<RpcRequestInfo>();
|
|
|
|
|
|
public static RpcRequestInfo get() {
|
|
|
- return rpcRequestInfo.get();
|
|
|
+ RpcRequestInfo rs = rpcRequestInfo.get();
|
|
|
+ if(rs == null) {
|
|
|
+ rs = new RpcRequestInfo();
|
|
|
+ }
|
|
|
+ return rs;
|
|
|
}
|
|
|
|
|
|
public static void remove() {
|