Quellcode durchsuchen

add coap网络组件

18339543638 vor 4 Jahren
Ursprung
Commit
2359db33d7

+ 1 - 1
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/coap/CoapExchangeMessage.java → jetlinks-core/src/main/java/org/jetlinks/core/message/codec/CoapExchangeMessage.java

@@ -1,4 +1,4 @@
-package org.jetlinks.core.message.codec.coap;
+package org.jetlinks.core.message.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;

+ 1 - 1
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/coap/CoapMessage.java → jetlinks-core/src/main/java/org/jetlinks/core/message/codec/CoapMessage.java

@@ -1,4 +1,4 @@
-package org.jetlinks.core.message.codec.coap;
+package org.jetlinks.core.message.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufUtil;

+ 1 - 2
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/coap/CoapResponseMessage.java → jetlinks-core/src/main/java/org/jetlinks/core/message/codec/CoapResponseMessage.java

@@ -1,4 +1,4 @@
-package org.jetlinks.core.message.codec.coap;
+package org.jetlinks.core.message.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufUtil;
@@ -7,7 +7,6 @@ import org.eclipse.californium.core.CoapResponse;
 import org.eclipse.californium.core.coap.CoAP;
 import org.eclipse.californium.core.coap.Option;
 import org.eclipse.californium.core.coap.OptionNumberRegistry;
-import org.jetlinks.core.message.codec.EncodedMessage;
 import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Nonnull;

+ 1 - 1
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/coap/DefaultCoapExchange.java → jetlinks-core/src/main/java/org/jetlinks/core/message/codec/DefaultCoapExchange.java

@@ -1,4 +1,4 @@
-package org.jetlinks.core.message.codec.coap;
+package org.jetlinks.core.message.codec;
 
 import org.eclipse.californium.core.CoapResource;
 import org.eclipse.californium.core.network.Exchange;

+ 1 - 2
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/coap/DefaultCoapMessage.java → jetlinks-core/src/main/java/org/jetlinks/core/message/codec/DefaultCoapMessage.java

@@ -1,11 +1,10 @@
-package org.jetlinks.core.message.codec.coap;
+package org.jetlinks.core.message.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
 import lombok.*;
 import org.eclipse.californium.core.coap.CoAP;
 import org.eclipse.californium.core.coap.Option;
-import org.jetlinks.core.message.codec.TextMessageParser;
 
 import javax.annotation.Nonnull;
 import java.util.ArrayList;

+ 1 - 2
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/coap/DefaultCoapResponseMessage.java → jetlinks-core/src/main/java/org/jetlinks/core/message/codec/DefaultCoapResponseMessage.java

@@ -1,4 +1,4 @@
-package org.jetlinks.core.message.codec.coap;
+package org.jetlinks.core.message.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
@@ -7,7 +7,6 @@ import lombok.Setter;
 import org.eclipse.californium.core.CoapResponse;
 import org.eclipse.californium.core.coap.CoAP;
 import org.eclipse.californium.core.coap.Option;
-import org.jetlinks.core.message.codec.TextMessageParser;
 
 import javax.annotation.Nonnull;
 import java.util.ArrayList;

+ 0 - 1
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/DeviceMessageDecoder.java

@@ -1,7 +1,6 @@
 package org.jetlinks.core.message.codec;
 
 import org.jetlinks.core.message.Message;
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
 import org.reactivestreams.Publisher;
 
 import javax.annotation.Nonnull;

+ 0 - 1
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/EncodedMessage.java

@@ -5,7 +5,6 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufUtil;
-import org.jetlinks.core.message.codec.coap.CoapMessage;
 
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;

+ 0 - 2
jetlinks-core/src/main/java/org/jetlinks/core/message/codec/MessageDecodeContext.java

@@ -1,8 +1,6 @@
 package org.jetlinks.core.message.codec;
 
 
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-
 import javax.annotation.Nonnull;
 
 /**

+ 0 - 1
jetlinks-core/src/test/java/org/jetlinks/core/message/codec/DefaultCoapMessageTest.java

@@ -5,7 +5,6 @@ import org.eclipse.californium.core.coap.CoAP;
 import org.eclipse.californium.core.coap.MediaTypeRegistry;
 import org.eclipse.californium.core.coap.Option;
 import org.eclipse.californium.core.coap.OptionNumberRegistry;
-import org.jetlinks.core.message.codec.coap.DefaultCoapMessage;
 import org.junit.Test;
 
 import java.util.Objects;

+ 0 - 1
jetlinks-core/src/test/java/org/jetlinks/core/message/codec/DefaultCoapResponseMessageTest.java

@@ -1,7 +1,6 @@
 package org.jetlinks.core.message.codec;
 
 import org.eclipse.californium.core.coap.CoAP;
-import org.jetlinks.core.message.codec.coap.DefaultCoapResponseMessage;
 import org.junit.Test;
 
 import static org.junit.Assert.*;