lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-06-16 21:03:22 +08:00
parent f6a4fbdf87
commit af80864e08
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/redkale/mq/HttpMessageProcessor.java
View File

@@ -56,7 +56,7 @@ public class HttpMessageProcessor implements MessageProcessor {
HttpContext context = server.getHttpServer().getContext(); HttpContext context = server.getHttpServer().getContext();
HttpMessageRequest request = new HttpMessageRequest(context, message); HttpMessageRequest request = new HttpMessageRequest(context, message);
if (multiconsumer) { if (multiconsumer) {
request.setRequestURI(request.getRequestURI().replaceFirst(this.restmodule, this.multimodule)); request.setRequestURI(request.getRequestURI().replaceFirst(this.multimodule, this.restmodule));
} }
HttpMessageResponse response = new HttpMessageResponse(context, request, callback, null, null, producer); HttpMessageResponse response = new HttpMessageResponse(context, request, callback, null, null, producer);
servlet.execute(request, response); servlet.execute(request, response);