身份证识别

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/QueueServiceImpl.java

@@ -16,7 +16,7 @@ import java.util.concurrent.ConcurrentLinkedQueue;
  * @author 颜佐光
  */
 @Component
-public class QueueServiceImpl implements QueueService, Runnable {
+public class QueueServiceImpl implements QueueService {
     private final BeanDao beanDao;
     private final Queue<QueueVo> queue = new ConcurrentLinkedQueue<>();
     private boolean isAsyncRun = false;
@@ -58,7 +58,12 @@ public class QueueServiceImpl implements QueueService, Runnable {
             }
             synchronized (this) {
                 isAsyncRun = true;
-                Thread thread = new Thread(this);
+                Thread thread = new Thread(new Runnable() {
+                    @Override
+                    public void run() {
+
+                    }
+                });
                 thread.setDaemon(true);
                 thread.start();
             }
@@ -88,8 +93,7 @@ public class QueueServiceImpl implements QueueService, Runnable {
         beanDao.createBinding(vo.getExchangeName(), vo.getQueueName(), vo.getRouteKey());
     }
 
-    @Override
-    public void run() {
+    private void handleQueue() {
         while (!this.queue.isEmpty()) {
             QueueVo vo = this.queue.poll();
             try {