|
|
@@ -63,17 +63,17 @@ namespace MySystem
|
|
|
// channel.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
|
// channel.Dispose();
|
|
|
_channel_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "SendMsg2");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "SendMsg2");
|
|
|
}
|
|
|
public void SendMsg3(string content, string QueueName)
|
|
|
{
|
|
|
_channel_kxs_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "SendMsg3");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "SendMsg3");
|
|
|
}
|
|
|
public void PushPosData(string content, string QueueName)
|
|
|
{
|
|
|
_channel_kxs_push.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "PushPosData");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "PushPosData");
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
@@ -127,13 +127,13 @@ namespace MySystem
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
op = false;
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "MQ消息队列单对单发送监听异常");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "MQ消息队列单对单发送监听异常");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
// channel.Dispose();
|
|
|
conn.Dispose();
|
|
|
- function.WriteLog(DateTime.Now.ToString(), "MQ测试");
|
|
|
+ Utils.WriteLog(DateTime.Now.ToString(), "MQ测试");
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
@@ -280,7 +280,7 @@ namespace MySystem
|
|
|
consumer.Received += (a, e) =>
|
|
|
{
|
|
|
string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
|
|
|
- function.WriteLog(MsgContent, "接收mq数据队列");
|
|
|
+ Utils.WriteLog(MsgContent, "接收mq数据队列");
|
|
|
if(QueueName == "QUEUE_KXS_TO_LKB_USER_INFO_DIVISION")
|
|
|
{
|
|
|
if(SycnJavaUsersService.Instance.Add(MsgContent))
|
|
|
@@ -315,7 +315,7 @@ namespace MySystem
|
|
|
{
|
|
|
string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
|
|
|
RedisDbconn.Instance.AddList("JavaUrlDataQueue", MsgContent);
|
|
|
- function.WriteLog(MsgContent, "接收mq接口数据队列");
|
|
|
+ Utils.WriteLog(MsgContent, "接收mq接口数据队列");
|
|
|
if(ApiDataFromJavaService.Instance.ApiDataDo(MsgContent))
|
|
|
{
|
|
|
channel.BasicAck(e.DeliveryTag, true); //收到回复后,RabbitMQ会直接在队列中删除这条消息
|
|
|
@@ -382,7 +382,7 @@ namespace MySystem
|
|
|
var consumer = new EventingBasicConsumer(channel);
|
|
|
consumer.Received += (a, e) =>
|
|
|
{
|
|
|
- Library.function.WriteLog(Encoding.Default.GetString(e.Body.ToArray()), "接收到的MQ消息");
|
|
|
+ Utils.WriteLog(Encoding.Default.GetString(e.Body.ToArray()), "接收到的MQ消息");
|
|
|
channel.BasicAck(e.DeliveryTag, true); //收到回复后,RabbitMQ会直接在队列中删除这条消息
|
|
|
};
|
|
|
channel.BasicConsume(QueueName, false, consumer);
|