删除无用代码

agent/src/main/java/cn/reghao/devops/agent/event/handler/EvtAppDeployHandler.java

@@ -3,7 +3,6 @@ package cn.reghao.devops.agent.event.handler;
 import cn.reghao.devops.common.agent.app.iface.AppDeploy;
 import cn.reghao.devops.common.machine.Machine;
 import cn.reghao.devops.common.msg.MessageSender;
-import cn.reghao.devops.common.msg.MsgQueue;
 import cn.reghao.devops.common.msg.event.EvtAppStatResult;
 import cn.reghao.jutil.jdk.event.message.Event;
 import cn.reghao.jutil.jdk.event.message.EventMessage;
@@ -44,7 +43,7 @@ public class EvtAppDeployHandler extends Handler {
         statResult.setDeploy(true);
         EventMessage evtMsg = EventMessage.evt(statResult);
         try {
-            messageSender.send(MsgQueue.managerTopic(), evtMsg);
+            messageSender.send("", evtMsg);
         } catch (IOException e) {
             e.printStackTrace();
         }

common/src/main/java/cn/reghao/devops/common/agent/machine/MachineEvent.java

@@ -2,7 +2,6 @@ package cn.reghao.devops.common.agent.machine;
 
 import cn.reghao.devops.common.machine.Machine;
 import cn.reghao.devops.common.msg.MessageSender;
-import cn.reghao.devops.common.msg.MsgQueue;
 import cn.reghao.devops.common.msg.event.EvtAgentHeartbeat;
 import cn.reghao.devops.common.msg.event.EvtAgentStart;
 import cn.reghao.jutil.jdk.event.message.EventMessage;
@@ -61,7 +60,7 @@ public class MachineEvent {
     private void pub(EventMessage eventMessage) {
         if (messageSender.isConnected()) {
             try {
-                messageSender.send(MsgQueue.managerTopic(), eventMessage);
+                messageSender.send("", eventMessage);
             } catch (IOException e) {
                 e.printStackTrace();
             }

common/src/main/java/cn/reghao/devops/common/msg/MsgQueue.java

@@ -1,14 +0,0 @@
-package cn.reghao.devops.common.msg;
-
-import cn.reghao.devops.common.msg.constant.AppId;
-
-/**
- * @author reghao
- * @date 2021-09-14 17:10:31
- */
-@Deprecated
-public class MsgQueue {
-    public static String managerTopic() {
-        return String.format("devops.%s", AppId.manager.name());
-    }
-}

common/src/main/java/cn/reghao/devops/common/msg/constant/Protocol.java

@@ -1,11 +0,0 @@
-package cn.reghao.devops.common.msg.constant;
-
-/**
- * agent 和 manager 通信使用的协议
- *
- * @author reghao
- * @date 2023-03-01 13:47:55
- */
-public enum Protocol {
-    local, ws, amqp
-}