diff --git a/net/src/test/java/com/zfoo/net/core/http/HttpServerController.java b/net/src/test/java/com/zfoo/net/core/http/HttpServerController.java index de89574d..7af89ecd 100644 --- a/net/src/test/java/com/zfoo/net/core/http/HttpServerController.java +++ b/net/src/test/java/com/zfoo/net/core/http/HttpServerController.java @@ -40,8 +40,6 @@ public class HttpServerController { var response = new HttpHelloResponse(); response.setMessage("Hello, this is the http server!"); - attachment.setHttpResponseStatus(HttpResponseStatus.OK); - NetContext.getRouter().send(session, response, attachment); } diff --git a/net/src/test/java/com/zfoo/net/core/http/HttpServerTest.java b/net/src/test/java/com/zfoo/net/core/http/HttpServerTest.java index 72674d27..d16ca874 100644 --- a/net/src/test/java/com/zfoo/net/core/http/HttpServerTest.java +++ b/net/src/test/java/com/zfoo/net/core/http/HttpServerTest.java @@ -21,6 +21,7 @@ import com.zfoo.protocol.util.StringUtils; import com.zfoo.util.ThreadUtils; import com.zfoo.util.net.HostAndPort; import io.netty.handler.codec.http.FullHttpRequest; +import io.netty.handler.codec.http.HttpResponseStatus; import org.junit.Ignore; import org.junit.Test; import org.springframework.context.support.ClassPathXmlApplicationContext; @@ -47,8 +48,9 @@ public class HttpServerTest { @Override public DecodedPacketInfo apply(FullHttpRequest fullHttpRequest) { var uri = StringUtils.trim(fullHttpRequest.uri()); + var attachment = HttpAttachment.valueOf(fullHttpRequest, HttpResponseStatus.OK); if (uri.equals("/hello")) { - return DecodedPacketInfo.valueOf(HttpHelloRequest.valueOf("other param"), HttpAttachment.valueOf(fullHttpRequest, null)); + return DecodedPacketInfo.valueOf(HttpHelloRequest.valueOf("other param"), attachment); } else { throw new RunException("未知的http路径[{}]", uri); }