diff --git a/src/org/redkale/mq/HttpMessageProcessor.java b/src/org/redkale/mq/HttpMessageProcessor.java index 8756a8c6a..8088d0ad7 100644 --- a/src/org/redkale/mq/HttpMessageProcessor.java +++ b/src/org/redkale/mq/HttpMessageProcessor.java @@ -21,6 +21,8 @@ import org.redkale.service.Service; */ public class HttpMessageProcessor implements MessageProcessor { + protected final boolean finest; + protected final Logger logger; protected final MessageProducer producer; @@ -39,6 +41,7 @@ public class HttpMessageProcessor implements MessageProcessor { public HttpMessageProcessor(Logger logger, MessageProducer producer, NodeHttpServer server, Service service, HttpServlet servlet) { this.logger = logger; + this.finest = logger.isLoggable(Level.FINEST); this.producer = producer; this.server = server; this.service = service; @@ -52,6 +55,7 @@ public class HttpMessageProcessor implements MessageProcessor { @Override public void process(MessageRecord message, Runnable callback) { try { + if (finest) logger.log(Level.FINEST, "HttpMessageProcessor.process message: " + message); if (multiconsumer) message.setResptopic(null); //不容许有响应 HttpContext context = server.getHttpServer().getContext(); HttpMessageRequest request = new HttpMessageRequest(context, message); diff --git a/src/org/redkale/mq/HttpMessageResponse.java b/src/org/redkale/mq/HttpMessageResponse.java index 72047c35f..e2710335e 100644 --- a/src/org/redkale/mq/HttpMessageResponse.java +++ b/src/org/redkale/mq/HttpMessageResponse.java @@ -6,6 +6,7 @@ package org.redkale.mq; import java.nio.ByteBuffer; +import java.util.logging.Level; import org.redkale.convert.*; import org.redkale.net.Response; import org.redkale.net.http.*; @@ -27,6 +28,8 @@ public class HttpMessageResponse extends HttpResponse { protected MessageProducer producer; + protected boolean finest; + protected Runnable callback; public HttpMessageResponse(HttpContext context, HttpMessageRequest request, Runnable callback, @@ -35,6 +38,7 @@ public class HttpMessageResponse extends HttpResponse { this.message = request.message; this.callback = callback; this.producer = producer; + this.finest = producer.logger.isLoggable(Level.FINEST); } public HttpMessageResponse(HttpContext context, MessageRecord message, Runnable callback, HttpResponseConfig config, MessageProducer producer) { @@ -81,6 +85,7 @@ public class HttpMessageResponse extends HttpResponse { @Override public void finish(int status, String message) { + if (finest) producer.logger.log(Level.FINEST, "HttpMessageResponse.finish status: " + status); if (this.message.isEmptyResptopic()) { if (callback != null) callback.run(); return; diff --git a/src/org/redkale/net/http/RestMapping.java b/src/org/redkale/net/http/RestMapping.java index 056ef97b6..4fc48e744 100644 --- a/src/org/redkale/net/http/RestMapping.java +++ b/src/org/redkale/net/http/RestMapping.java @@ -51,7 +51,7 @@ public @interface RestMapping { * * @return boolean */ - boolean rpconly() default true; + boolean rpconly() default false; /** * 是否鉴权,默认需要鉴权, 对应@HttpMapping.auth