|
@@ -248,7 +248,6 @@ namespace MySystem
|
|
|
RedisDbconn.Instance.AddList("JavaUrlDataQueue", MsgContent);
|
|
RedisDbconn.Instance.AddList("JavaUrlDataQueue", MsgContent);
|
|
|
function.WriteLog(MsgContent, "接收mq接口数据队列");
|
|
function.WriteLog(MsgContent, "接收mq接口数据队列");
|
|
|
if(ApiDataFromJavaService.Instance.ApiDataDo(MsgContent))
|
|
if(ApiDataFromJavaService.Instance.ApiDataDo(MsgContent))
|
|
|
->>>>>>> test-mqserver
|
|
|
|
|
{
|
|
{
|
|
|
channel.BasicAck(e.DeliveryTag, true); //收到回复后,RabbitMQ会直接在队列中删除这条消息
|
|
channel.BasicAck(e.DeliveryTag, true); //收到回复后,RabbitMQ会直接在队列中删除这条消息
|
|
|
}
|
|
}
|