【发布时间】:2015-05-06 16:59:19
【问题描述】:
我创建了一个基本的应用程序来用 C# 管理 MSMQ。
我使用这种方法在我的事务消息队列中创建消息:
/// <summary>
/// Method to send message in message queue
/// </summary>
/// <param name="mq">message queue (to)</param>
/// <param name="messageBody">message body</param>
/// <param name="messageLabel">message label</param>
public static void sendMessage(MessageQueue mq, string messageBody, string messageLabel)
{
MessageQueueTransaction mqt = new MessageQueueTransaction();
try
{
Message m = new Message(messageBody, new XmlMessageFormatter(new String[] { "System.String,mscorlib" }));
m.BodyType = 0;
mqt.Begin();
mq.Send(m, messageLabel, mqt);
mqt.Commit();
}
catch (Exception ex)
{
string s = ex.Message;
mqt.Abort();
}
finally
{
mq.Close();
}
}
对于消息处理(在控制台中写入内容消息),我使用这个:
/// <summary>
/// Get all messages in MSMQ
/// </summary>
/// <param name="mq"> MSMQ </param>
public static void getMessage(MessageQueue mq)
{
Message[] messages = mq.GetAllMessages();
try
{
foreach (Message m in messages)
{
Console.WriteLine("Message" + m.Label = ": " + m.Body.ToString());
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
所有消息都在消息数组中,但我在 foreach 语句的行中有一个无效操作异常。 当我使用调试器时,我可以看到很多消息属性都有异常。 我只是想确保我在消息中发送标签和正文以便稍后获取。 send 或 get 方法是否有错误(或两者都有)? --谢谢
【问题讨论】:
-
请为您的问题找到一个更有意义的标题!
标签: c# message-queue msmq invalidoperationexception