Commit ab478879 by 赵剑炜

rabbitMQ添加消息

parent 28cc5101
...@@ -42,6 +42,7 @@ public class CabinetLogReceiver { ...@@ -42,6 +42,7 @@ public class CabinetLogReceiver {
logRecordDTO.setHttpMethod("RabbitMQ"); logRecordDTO.setHttpMethod("RabbitMQ");
logRecordDTO.setLogContent("CabinetLogsRecord"); logRecordDTO.setLogContent("CabinetLogsRecord");
logRecordDTO.setRequestParams(msg); logRecordDTO.setRequestParams(msg);
logRecordDTO.setLogType(30);
logRecordDTO.setRequestUrl("queues = \"CabinetLogsRecord\""); logRecordDTO.setRequestUrl("queues = \"CabinetLogsRecord\"");
try { try {
// 手动确认消息 // 手动确认消息
......
...@@ -40,6 +40,7 @@ public class OutInLogsByCabinetReceiver { ...@@ -40,6 +40,7 @@ public class OutInLogsByCabinetReceiver {
logRecordDTO.setHttpMethod("RabbitMQ"); logRecordDTO.setHttpMethod("RabbitMQ");
logRecordDTO.setLogContent("CabinetLogsRecord"); logRecordDTO.setLogContent("CabinetLogsRecord");
logRecordDTO.setRequestParams(msg); logRecordDTO.setRequestParams(msg);
logRecordDTO.setLogType(30);
logRecordDTO.setRequestUrl("queues = \"CabinetLogsRecord\""); logRecordDTO.setRequestUrl("queues = \"CabinetLogsRecord\"");
try { try {
System.out.println("msg = " + msg); System.out.println("msg = " + msg);
......
...@@ -41,6 +41,7 @@ public class OutInLogsReceiver { ...@@ -41,6 +41,7 @@ public class OutInLogsReceiver {
logRecordDTO.setHttpMethod("RabbitMQ"); logRecordDTO.setHttpMethod("RabbitMQ");
logRecordDTO.setLogContent("OrderResult"); logRecordDTO.setLogContent("OrderResult");
logRecordDTO.setRequestParams(msg); logRecordDTO.setRequestParams(msg);
logRecordDTO.setLogType(30);
logRecordDTO.setRequestUrl("queues = \"11111\""); logRecordDTO.setRequestUrl("queues = \"11111\"");
try { try {
// System.out.println("msg = " + msg); // System.out.println("msg = " + msg);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论