|
@@ -63,10 +63,12 @@ namespace MySystem
|
|
|
// channel.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
// channel.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
|
// channel.Dispose();
|
|
// channel.Dispose();
|
|
|
_channel_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
_channel_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
|
|
|
+ function.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "SendMsg2");
|
|
|
}
|
|
}
|
|
|
public void SendMsg3(string content, string QueueName)
|
|
public void SendMsg3(string content, string QueueName)
|
|
|
{
|
|
{
|
|
|
_channel_kxs_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
_channel_kxs_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
|
|
|
|
|
+ function.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "SendMsg3");
|
|
|
}
|
|
}
|
|
|
#endregion
|
|
#endregion
|
|
|
|
|
|