serviceType

src/main/java/org/redkale/mq/MessageClientConsumer.java

@@ -28,7 +28,7 @@ public abstract class MessageClientConsumer {
 
     protected final MessageClientProcessor processor;
 
-    protected final Logger logger;
+    protected final Logger logger = Logger.getLogger(this.getClass().getSimpleName());
 
     protected volatile boolean closed;
 
@@ -38,7 +38,6 @@ public abstract class MessageClientConsumer {
         Objects.requireNonNull(consumerid);
         Objects.requireNonNull(processor);
         this.messageAgent = messageAgent;
-        this.logger = messageAgent.logger;
         this.topics = topics;
         this.consumerid = consumerid;
         this.processor = processor;

src/main/java/org/redkale/mq/MessageClientProducer.java

@@ -20,15 +20,14 @@ import java.util.logging.Logger;
  */
 public abstract class MessageClientProducer {
 
-    protected final Logger logger;
+    protected final Logger logger = Logger.getLogger(this.getClass().getSimpleName());
 
     protected final String name;
 
     protected final AtomicBoolean closed = new AtomicBoolean();
 
-    protected MessageClientProducer(String name, Logger logger) {
+    protected MessageClientProducer(String name) {
         this.name = name;
-        this.logger = logger;
     }
 
     public abstract CompletableFuture<Void> apply(MessageRecord message);

src/main/java/org/redkale/service/AbstractService.java

@@ -9,6 +9,7 @@ import java.util.concurrent.*;
 import org.redkale.annotation.Resource;
 import org.redkale.boot.Application;
 import org.redkale.net.WorkThread;
+import org.redkale.net.sncp.Sncp;
 
 /**
  *
@@ -31,7 +32,7 @@ public abstract class AbstractService implements Service {
     }
 
     protected Class serviceType() {
-        return serviceType;
+        return serviceType == null ? Sncp.getServiceType(getClass()) : serviceType;
     }
 
     /**