销售电话: 1-800-867-1380

MessageSender 类

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

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

命名空间:  Microsoft.ServiceBus.Messaging
程序集:  Microsoft.ServiceBus(在 Microsoft.ServiceBus.dll 中)

public abstract class MessageSender : MessageClientEntity

MessageSender 类型公开以下成员。

  名称说明
公共属性BatchFlushInterval获取批刷新间隔。
受保护属性BatchingEnabled获取一个值,用于指示是否启用了批处理。
公共属性IsClosed (从 ClientEntity 继承。)
公共属性Path获取相对于 MessagingFactory 基址的队列路径或主题路径。
公共属性RetryPolicy (从 ClientEntity 继承。)
受保护属性ThisLock (从 ClientEntity 继承。)
页首

  名称说明
公共方法AbortPerforms abort functionality on the messaging entity. (从 ClientEntity 继承。)
公共方法BeginClose开始用于关闭消息客户端实体的异步操作。 (从 MessageClientEntity 继承。)
公共方法BeginSend开始发送中转消息的异步请求。
公共方法BeginSendBatch开始按批发送中转消息的异步请求。
公共方法CloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. (从 ClientEntity 继承。)
公共方法CloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (从 ClientEntity 继承。)
公共方法EndClose完成用于关闭消息客户端实体的异步操作。 (从 MessageClientEntity 继承。)
公共方法EndSend结束发送消息的异步请求。
公共方法EndSendBatch结束按批发送消息的异步请求。
公共方法Equals (从 Object 继承。)
受保护方法FaultFor internal use only. Do not inherit from this class. (从 ClientEntity 继承。)
受保护方法Finalize (从 Object 继承。)
公共方法GetHashCode (从 Object 继承。)
公共方法GetType (从 Object 继承。)
受保护方法MemberwiseClone (从 Object 继承。)
受保护方法OnAbort (从 ClientEntity 继承。)
受保护方法OnBeginCancelScheduledMessage
受保护方法OnBeginClose (从 ClientEntity 继承。)
受保护方法OnBeginOpen (从 ClientEntity 继承。)
受保护方法OnBeginScheduleMessage
受保护方法OnBeginSend允许具体实现来定义发送消息时执行的操作。用户无法在具体类中实现此方法。
受保护方法OnBeginSendEventData
受保护方法OnClose (从 ClientEntity 继承。)
受保护方法OnClosed (从 ClientEntity 继承。)
受保护方法OnEndCancelScheduledMessage
受保护方法OnEndClose (从 ClientEntity 继承。)
受保护方法OnEndOpen (从 ClientEntity 继承。)
受保护方法OnEndScheduleMessage
受保护方法OnEndSend执行“结束发送”操作。用户无法在具体类中实现此方法。
受保护方法OnEndSendEventData
受保护方法OnFaulted (从 ClientEntity 继承。)
受保护方法OnOpen (从 ClientEntity 继承。)
受保护方法OnOpened (从 ClientEntity 继承。)
受保护方法OnSend允许具体实现覆盖(如果需要)以异步方式发送消息时执行的操作。
公共方法Send发送指定的中转消息。
公共方法SendAsync异步发送指定的中转消息。
公共方法SendBatch发送一组中转消息(用于批处理)。
公共方法SendBatchAsync异步发送一组中转消息(用于批处理)。
受保护方法ThrowIfClosed (从 ClientEntity 继承。)
受保护方法ThrowIfDisposed (从 ClientEntity 继承。)
受保护方法ThrowIfDisposedOrImmutable (从 ClientEntity 继承。)
受保护方法ThrowIfDisposedOrNotOpen (从 ClientEntity 继承。)
受保护方法ThrowIfFaulted (从 ClientEntity 继承。)
公共方法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 个剩余字符)
感谢您的反馈

社区附加资源

添加
Microsoft 正在进行一项网上调查,以了解您对 MSDN 网站的意见。 如果您选择参加,我们将会在您离开 MSDN 网站时向您显示该网上调查。

是否要参加?
显示:
© 2014 Microsoft