导出 (0) 打印
全部展开
此主题尚未评级 - 评价此主题

MessageSender 类

注:本页面内容可能不完全适用中国大陆地区运营的 Windows Azure服务。如要了解不同地区 Windows Azure 服务的差异, 请参考本网站.

MessageSender 类用于从 Service Bus 发送消息。你可以使用 QueueClient 类来发送和接收消息且无需创建 MessageSender 对象,不过,你也可以使用 MessageSenderMessageReceiver 在实体上创建发送器和接收器,而无需了解该实体是主题还是队列。

System..::..Object
  Microsoft.ServiceBus.Messaging..::..MessageClientEntity
    Microsoft.ServiceBus.Messaging..::..MessageSender

命名空间:  Microsoft.ServiceBus.Messaging
程序集:  Microsoft.ServiceBus(在 Microsoft.ServiceBus.dll 中)
[<AbstractClassAttribute>]
type MessageSender =  
    class
        inherit MessageClientEntity
    end

MessageSender 类型公开以下成员。

  名称说明
公共属性BatchFlushInterval获取批刷新间隔。
受保护属性BatchingEnabled获取一个值,用于指示是否启用了批处理。
公共属性IsClosed获取或设置一个值,用于指示消息客户端实体是否已关闭。 (从 MessageClientEntity 继承。)
公共属性Path获取相对于 MessagingFactory 基址的队列路径或主题路径。
公共属性RetryPolicy获取或设置与此实例关联的用于确定是否应重试请求的重试策略。 (从 MessageClientEntity 继承。)
受保护属性ThisLock获取用于锁定 MessageClientEntity 实例的对象。 (从 MessageClientEntity 继承。)
页首
  名称说明
公共方法Abort中止消息客户端实体,并将其置于正在关闭状态。 (从 MessageClientEntity 继承。)
公共方法BeginClose开始用于关闭消息客户端实体的异步操作。 (从 MessageClientEntity 继承。)
公共方法BeginSend开始发送中转消息的异步请求。
公共方法BeginSendBatch开始按批发送中转消息的异步请求。
公共方法Close关闭消息客户端实体,并将其置于已关闭状态。 (从 MessageClientEntity 继承。)
公共方法CloseAsync异步关闭消息客户端实体并将其置于已关闭状态。 (从 MessageClientEntity 继承。)
公共方法EndClose完成用于关闭消息客户端实体的异步操作。 (从 MessageClientEntity 继承。)
公共方法EndSend结束发送消息的异步请求。
公共方法EndSendBatch结束按批发送消息的异步请求。
公共方法Equals (从 Object 继承。)
受保护方法Fault将消息客户端实体置于故障状态。 (从 MessageClientEntity 继承。)
受保护方法Finalize (从 Object 继承。)
公共方法GetHashCode (从 Object 继承。)
公共方法GetType (从 Object 继承。)
受保护方法MemberwiseClone (从 Object 继承。)
受保护方法OnAbort在调用 Abort 操作时执行。 (从 MessageClientEntity 继承。)
受保护方法OnBeginClose在调用 BeginClose 操作时执行。 (从 MessageClientEntity 继承。)
受保护方法OnBeginOpen在调用相关操作并开始打开消息客户端实体时执行。 (从 MessageClientEntity 继承。)
受保护方法OnBeginSend允许具体实现来定义发送消息时执行的操作。用户无法在具体类中实现此方法。
受保护方法OnClose在调用 Close 操作时执行。 (从 MessageClientEntity 继承。)
受保护方法OnClosed当消息客户端实体转换为正在关闭状态时发生。 (从 MessageClientEntity 继承。)
受保护方法OnEndClose在调用 EndClose 操作时执行。 (从 MessageClientEntity 继承。)
受保护方法OnEndOpen在调用相关操作并结束打开消息客户端实体时执行。 (从 MessageClientEntity 继承。)
受保护方法OnEndSend执行“结束发送”操作。用户无法在具体类中实现此方法。
受保护方法OnFaulted在调用 Fault 操作时执行。 (从 MessageClientEntity 继承。)
受保护方法OnOpen在调用用于打开消息客户端实体的操作时执行。 (从 MessageClientEntity 继承。)
受保护方法OnOpened在消息客户端实体打开时执行。 (从 MessageClientEntity 继承。)
受保护方法OnRuntimeDescriptionChanged当运行时描述发生更改时引发事件。 (从 MessageClientEntity 继承。)
受保护方法OnSend允许具体实现覆盖(如果需要)以异步方式发送消息时执行的操作。
公共方法Send发送指定的中转消息。
公共方法SendAsync异步发送指定的中转消息。
公共方法SendBatch发送一组中转消息(用于批处理)。
公共方法SendBatchAsync异步发送一组中转消息(用于批处理)。
受保护方法ThrowIfClosed如果消息客户端实体已关闭,则会引发异常。 (从 MessageClientEntity 继承。)
受保护方法ThrowIfDisposed如果消息客户端实体已释放,则会引发异常。 (从 MessageClientEntity 继承。)
受保护方法ThrowIfDisposedOrImmutable如果客户端已释放或不可变,则会引发异常。 (从 MessageClientEntity 继承。)
受保护方法ThrowIfDisposedOrNotOpen如果客户端已释放或未打开,则会引发异常。 (从 MessageClientEntity 继承。)
受保护方法ThrowIfFaulted如果客户端发生故障,则会引发异常。 (从 MessageClientEntity 继承。)
公共方法ToString (从 Object 继承。)
页首

Note that the default message receive mode is PeekLock, which ensures reliable message receiving.

The following example sends messages to a queue.

Uri serviceUri = ServiceBusEnvironment.CreateServiceUri("sb", ServiceNamespace, string.Empty); 

MessagingFactory factory = MessagingFactory.Create(serviceUri, credentials); 

MessageSender myMessageSender = factory.CreateMessageSender(queueName); 

List<BrokeredMessage> messageList = new List<BrokeredMessage>();
messageList.Add(CreateIssueMessage("1", "Package lost"));
messageList.Add(CreateIssueMessage("2", "Package damaged"));
messageList.Add(CreateIssueMessage("3", "Package defective"));

foreach (BrokeredMessage message in messageList)
{
    myMessageSender.Send(message);
    Console.WriteLine(
    string.Format("Message sent: Id = {0}, Body = {1}", message.MessageId, message.GetBody<string>()));
}

Any public static (Shared in Visual Basic) members of this type are thread safe. Instance members are also guaranteed to be thread safe.

本文是否对您有所帮助?
(1500 个剩余字符)
感谢您的反馈

社区附加资源

添加
显示:
© 2014 Microsoft. 版权所有。