diff --git a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java index 5b63b143f..c8e6418d3 100755 --- a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java +++ b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/RenameProtocolSupport.java @@ -22,10 +22,12 @@ import org.jetlinks.core.device.*; import org.jetlinks.core.event.EventBus; import org.jetlinks.core.message.codec.DeviceMessageCodec; +import org.jetlinks.core.message.codec.MessageParserFactory; import org.jetlinks.core.message.codec.TraceDeviceMessageCodec; import org.jetlinks.core.message.codec.Transport; import org.jetlinks.core.message.interceptor.DeviceMessageSenderInterceptor; import org.jetlinks.core.metadata.*; +import org.jetlinks.core.principal.PrincipalMetadata; import org.jetlinks.core.route.Route; import org.jetlinks.core.server.ClientConnection; import org.jetlinks.core.server.DeviceGatewayContext; @@ -156,6 +158,11 @@ public Mono getConfigMetadata(Transport transport) { return target.getConfigMetadata(transport); } + @Override + public Flux getAllConfigMetadata(Transport transport) { + return target.getAllConfigMetadata(transport); + } + @Override public void init(Map configuration) { target.init(configuration); @@ -244,6 +251,16 @@ public Mono doBeforeDeviceCreate(Transport transport, DeviceInfo dev return target.doBeforeDeviceCreate(transport, deviceInfo); } + @Override + public Flux getDevicePrincipalMetadata(Transport transport, DeviceInfo deviceInfo) { + return target.getDevicePrincipalMetadata(transport, deviceInfo); + } + + @Override + public Mono getMessageParser(Transport transport) { + return target.getMessageParser(transport); + } + @Override public int getOrder() { return target.getOrder(); diff --git a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java index c53057acd..b36209af8 100644 --- a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java +++ b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/local/LocalFileProtocolSupport.java @@ -22,14 +22,17 @@ import org.jetlinks.core.ProtocolSupport; import org.jetlinks.core.device.*; import org.jetlinks.core.message.codec.DeviceMessageCodec; +import org.jetlinks.core.message.codec.MessageParserFactory; import org.jetlinks.core.message.codec.Transport; import org.jetlinks.core.message.interceptor.DeviceMessageSenderInterceptor; import org.jetlinks.core.metadata.*; +import org.jetlinks.core.principal.PrincipalMetadata; import org.jetlinks.core.route.Route; import org.jetlinks.core.server.ClientConnection; import org.jetlinks.core.server.DeviceGatewayContext; import org.jetlinks.core.spi.ProtocolSupportProvider; import org.jetlinks.core.spi.ServiceContext; +import org.jetlinks.core.things.ThingRpcSupportChain; import org.jetlinks.supports.protocol.management.jar.ProtocolClassLoader; import org.springframework.util.ClassUtils; import org.springframework.util.StringUtils; @@ -231,6 +234,11 @@ public Mono getConfigMetadata(Transport transport) { return loaded.getConfigMetadata(transport); } + @Override + public Flux getAllConfigMetadata(Transport transport) { + return loaded.getAllConfigMetadata(transport); + } + @Override public Mono getInitConfigMetadata() { return loaded.getInitConfigMetadata(); @@ -325,6 +333,21 @@ public Mono doBeforeDeviceCreate(Transport transport, DeviceInfo dev return loaded.doBeforeDeviceCreate(transport, deviceInfo); } + @Override + public Flux getDevicePrincipalMetadata(Transport transport, DeviceInfo deviceInfo) { + return loaded.getDevicePrincipalMetadata(transport, deviceInfo); + } + + @Override + public ThingRpcSupportChain getRpcChain() { + return loaded.getRpcChain(); + } + + @Override + public Mono getMessageParser(Transport transport) { + return loaded.getMessageParser(transport); + } + @Override public int getOrder() { return loaded.getOrder(); @@ -349,4 +372,17 @@ public String getDocument(Transport transport) { public boolean isEmbedded() { return loaded.isEmbedded(); } + + @Override + public boolean isWrapperFor(Class type) { + return type.isInstance(this) || loaded.isWrapperFor(type); + } + + @Override + public T unwrap(Class type) { + if (type.isInstance(this)) { + return type.cast(this); + } + return loaded.unwrap(type); + } }