diff --git a/src/main/java/org/redkale/net/client/ClientCodec.java b/src/main/java/org/redkale/net/client/ClientCodec.java index e259ff199..de51fd1fc 100644 --- a/src/main/java/org/redkale/net/client/ClientCodec.java +++ b/src/main/java/org/redkale/net/client/ClientCodec.java @@ -37,7 +37,7 @@ public abstract class ClientCodec connection) { + protected ClientCodec(ClientConnection connection) { Objects.requireNonNull(connection); this.connection = connection; } @@ -118,9 +118,7 @@ public abstract class ClientCodec respFuture, P message, Throwable exc) { R request = respFuture.request; - if (request != null) { - Traces.currentTraceid(request.getTraceid()); - } + Traces.currentTraceid(request.getTraceid()); AsyncIOThread readThread = connection.channel.getReadIOThread(); final WorkThread workThread = request.workThread; try { diff --git a/src/main/java/org/redkale/net/http/HttpSimpleRequest.java b/src/main/java/org/redkale/net/http/HttpSimpleRequest.java index 55d1ac1e3..6c469bff8 100644 --- a/src/main/java/org/redkale/net/http/HttpSimpleRequest.java +++ b/src/main/java/org/redkale/net/http/HttpSimpleRequest.java @@ -139,6 +139,11 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ return sb.toString(); } + public HttpSimpleRequest formUrlencoded() { + this.headers.put("Content-Type", "x-www-form-urlencoded"); + return this; + } + public HttpSimpleRequest rpc(boolean rpc) { this.rpc = rpc; return this;