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);

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;

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