in src/plugins/AWS2SNSPlugin.ts [44:64]
sns[name] = function (params: any, callback: any) {
const to = params.TopicArn
? `Topic/${params.TopicArn.slice(params.TopicArn.lastIndexOf(':') + 1)}`
: params.TargetArn
? `Target/${params.TargetArn.slice(params.TargetArn.lastIndexOf(':') + 1)}`
: params.PhoneNumber
? `Phone/${params.PhoneNumber}`
: '???';
const operation = `AWS/SNS/${name}/${to}`;
const span = ContextManager.current.newExitSpan(operation, Component.AWS_SNS, Component.HTTP);
const arn = params.TopicArn || params.TargetArn;
span.component = Component.AWS_SNS;
span.layer = SpanLayer.MQ;
if (arn) span.tag(Tag.arn(arn));
if (params.TopicArn) params = addTraceId(params, span);
return execute(span, this, _func, params, callback, 'mqBroker');
};