init

fn-rabbitmq/src/main/java/net/yaoyi/pipeline/rabbitmq/MultiResultProducer.java

@@ -73,7 +73,7 @@ public class MultiResultProducer implements PojoRequestHandler<List<ImageMultiMs
         String messageId = UUID.randomUUID().toString().replaceAll("-", "");
         try {
             AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().messageId(messageId).build();
-            channel.basicPublish(EXCHANGE_NAME, QUEUE_NAME, props, json.getBytes(StandardCharsets.UTF_8));
+            channel.basicPublish("", QUEUE_NAME, props, json.getBytes(StandardCharsets.UTF_8));
             log.info("消息发送成功，seq:{}, messageId:{}. body:{}", seq, messageId, json);
         } catch (IOException e) {
             log.error("消息发送失败: {}", json, e);
@@ -88,7 +88,6 @@ public class MultiResultProducer implements PojoRequestHandler<List<ImageMultiMs
             }
         } catch (Exception e) {
             log.error("channel 关闭失败");
-        } finally {
             RabbitMQHelper.close(channel, connection);
         }
     }