本文整理了Java中com.alibaba.dubbo.rpc.RpcResult.setAttachment
方法的一些代码示例,展示了RpcResult.setAttachment
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RpcResult.setAttachment
方法的具体详情如下:
包路径:com.alibaba.dubbo.rpc.RpcResult
类名称:RpcResult
方法名:setAttachment
[英]Append all items from the map into the attachment, if map is empty then nothing happens
[中]将地图中的所有项目附加到附件中,如果地图为空,则不会发生任何事情
代码示例来源:origin: remoting/dubbox
private void logMessageLength(Object result, int bytes) {
if (bytes <= 0) { return; }
if (result instanceof Request) {
try {
((RpcInvocation) ((Request) result).getData()).setAttachment(
Constants.INPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
} else if (result instanceof Response) {
try {
((RpcResult) ((Response) result).getResult()).setAttachment(
Constants.OUTPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
}
}
代码示例来源:origin: remoting/dubbox
private void logMessageLength(Object result, int bytes) {
if (bytes <= 0) { return; }
if (result instanceof Request) {
try {
((RpcInvocation) ((Request) result).getData()).setAttachment(
Constants.INPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
} else if (result instanceof Response) {
try {
((RpcResult) ((Response) result).getResult()).setAttachment(
Constants.OUTPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
}
}
代码示例来源:origin: net.jahhan/dubbo-rpc-default
private void logMessageLength(Object result, int bytes) {
if (bytes <= 0) { return; }
if (result instanceof Request) {
try {
((RpcInvocation) ((Request) result).getData()).setAttachment(
Constants.INPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
} else if (result instanceof Response) {
try {
((RpcResult) ((Response) result).getResult()).setAttachment(
Constants.OUTPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
}
}
代码示例来源:origin: com.alibaba/dubbo-rpc-default
private void logMessageLength(Object result, int bytes) {
if (bytes <= 0) { return; }
if (result instanceof Request) {
try {
((RpcInvocation) ((Request) result).getData()).setAttachment(
Constants.INPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
} else if (result instanceof Response) {
try {
((RpcResult) ((Response) result).getResult()).setAttachment(
Constants.OUTPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
}
}
代码示例来源:origin: com.alibaba/dubbo
private void logMessageLength(Object result, int bytes) {
if (bytes <= 0) {
return;
}
if (result instanceof Request) {
try {
((RpcInvocation) ((Request) result).getData()).setAttachment(
Constants.INPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
} else if (result instanceof Response) {
try {
((RpcResult) ((Response) result).getResult()).setAttachment(
Constants.OUTPUT_KEY, String.valueOf(bytes));
} catch (Throwable e) {
/* ignore */
}
}
}
内容来源于网络,如有侵权,请联系作者删除!