fix: 移除mqtt连接时的链路追踪 (#428)
This commit is contained in:
parent
04c1071fb4
commit
7f69c8f487
|
|
@ -130,13 +130,7 @@ class MqttServerDeviceGateway extends AbstractDeviceGateway {
|
|||
.onErrorResume(err -> {
|
||||
log.error(err.getMessage(), err);
|
||||
return Mono.empty();
|
||||
})
|
||||
.as(MonoTracer
|
||||
.create(SpanName.connection(connection.getClientId()),
|
||||
builder -> {
|
||||
builder.setAttribute(clientId, connection.getClientId());
|
||||
builder.setAttribute(SpanKey.address, connection.getClientAddress().toString());
|
||||
})),
|
||||
}),
|
||||
Integer.MAX_VALUE)
|
||||
.subscribe();
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue