From a11127ea58efe71a0934801a36bb5b9831be4041 Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Wed, 17 Jun 2020 13:39:08 +0800
Subject: [PATCH]

---
 src/org/redkale/mq/HttpMessageClient.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/org/redkale/mq/HttpMessageClient.java b/src/org/redkale/mq/HttpMessageClient.java
index 7f1df8296..8af8c12e0 100644
--- a/src/org/redkale/mq/HttpMessageClient.java
+++ b/src/org/redkale/mq/HttpMessageClient.java
@@ -5,6 +5,7 @@
  */
 package org.redkale.mq;
 
+import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.atomic.AtomicLong;
 import org.redkale.convert.ConvertType;
@@ -41,7 +42,9 @@ public class HttpMessageClient extends MessageClient {
         if (path != null && !path.isEmpty() && module.startsWith(path)) module = module.substring(path.length());
         module = module.substring(1); //去掉/
         module = module.substring(0, module.indexOf('/'));
-        return messageAgent.generateHttpReqTopic(module);
+        Map<String, String> headers = request.getHeaders();
+        String resname = headers == null ? "" : headers.getOrDefault(Rest.REST_HEADER_RESOURCE_NAME, "");
+        return messageAgent.generateHttpReqTopic(module, resname);
     }
 
     public final void produceMessage(HttpSimpleRequest request) {