代码优化

framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/context/RocketMQContextHolder.java

@@ -285,28 +285,6 @@ public final class RocketMQContextHolder {
         }
     }
 
-    /**
-     * 发送异步消息
-     *
-     * @param topic   消息主题
-     * @param payload 消息内容
-     */
-    public static void sendAsync(@NonNull String topic, @NonNull Object payload) {
-        sendAsync(topic, payload, null);
-    }
-
-    /**
-     * 发送异步消息
-     *
-     * @param topic    消息主题
-     * @param payload  消息内容
-     * @param ordering 顺序消息标识
-     */
-    public static void sendAsync(@NonNull String topic, @NonNull Object payload, String ordering) {
-        Message message = serialize(topic, payload, ordering);
-        getProducer().sendAsync(message);
-    }
-
     /**
      * 发送事务消息
      *
@@ -382,4 +360,26 @@ public final class RocketMQContextHolder {
             throw new RuntimeException(e);
         }
     }
+
+    /**
+     * 发送异步消息
+     *
+     * @param topic   消息主题
+     * @param payload 消息内容
+     */
+    public static void sendAsync(@NonNull String topic, @NonNull Object payload) {
+        sendAsync(topic, payload, null);
+    }
+
+    /**
+     * 发送异步消息
+     *
+     * @param topic    消息主题
+     * @param payload  消息内容
+     * @param ordering 顺序消息标识
+     */
+    public static void sendAsync(@NonNull String topic, @NonNull Object payload, String ordering) {
+        Message message = serialize(topic, payload, ordering);
+        getProducer().sendAsync(message);
+    }
 }