你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

MessageSender 类

定义

MessageSender 类用于从服务总线发送消息。

public abstract class MessageSender : Microsoft.ServiceBus.Messaging.MessagingEntityClient
type MessageSender = class
    inherit MessagingEntityClient
Public MustInherit Class MessageSender
Inherits MessagingEntityClient
继承

注解

请注意,默认情况下,消息传递机制不提供所有时间可靠的消息接收。 服务总线在消息离开系统后将其删除。 若要保证送达,可以使用 PeekLock 传递模式。

//********************************************************************************
//                             Sending messages to a Queue
//********************************************************************************

// Create a sender
MessageSender myMessageSender = myQueueClient.CreateSender(SendMode.Default);

// Send messages
List<object> Issues = new List<object>();
foreach (var issue in Issues)
{
myMessageSender.Send(new BrokeredMessage(issue));
}
//********************************************************************************
//                           Recieving messages from a Queue
//********************************************************************************

// Create a receiver
MessageReceiver myMessageReceiver = 
myQueueClient.CreateReceiver(ReceiveMode.PeekLock);

// Receive messages
for (int count = 0; count < Issues.Count; count++)
{
var message = myMessageReceiver.Receive();
message.Complete();
}

属性

BatchFlushInterval

获取批量刷新间隔。

BatchingEnabled

获取一个值,该值指示是否启用批处理。

IsClosed

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
Path

获取队列、主题或订阅相对于 MessagingFactory 基址的路径。

(继承自 MessagingEntityClient)
RefreshEntityRuntimeDescription

MessageSender 类用于从服务总线发送消息。

RetryPolicy

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
SupportsGetRuntimeEntityDescription

MessageSender 类用于从服务总线发送消息。

ThisLock

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)

方法

Abort()

对消息传送实体执行中止功能。

(继承自 ClientEntity)
Close()

向服务总线发送清理消息,以指示实体的使用完成。

(继承自 ClientEntity)
CloseAsync()

以异步方式将清理消息发送到服务总线,以指示实体的使用完成。

(继承自 ClientEntity)
Fault()

仅限内部使用。 请勿从此类继承。

(继承自 ClientEntity)
OnAbort()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnBeginCancelScheduledMessage(TrackingContext, IEnumerable<Int64>, TimeSpan, AsyncCallback, Object)

这样,具体实现就可以根据需要替代 () 取消计划发送应执行的操作

OnBeginClose(TimeSpan, AsyncCallback, Object)

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnBeginOpen(TimeSpan, AsyncCallback, Object)

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnBeginScheduleMessage(TrackingContext, IEnumerable<BrokeredMessage>, TimeSpan, AsyncCallback, Object)

这样,具体实现就可以根据需要替代 () 计划发送时应执行的操作

OnBeginSend(TrackingContext, IEnumerable<BrokeredMessage>, Boolean, TimeSpan, AsyncCallback, Object)

执行开始发送操作。 此方法适用于内部使用,不能由用户在具体类中实现。

OnBeginSendEventData(TrackingContext, IEnumerable<EventData>, TimeSpan, AsyncCallback, Object)

执行开始发送事件数据操作。 此方法适用于内部使用,不能由用户在具体类中实现。

OnClose(TimeSpan)

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnClosed()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnEndCancelScheduledMessage(IAsyncResult)

结束取消计划消息时引发事件。

OnEndClose(IAsyncResult)

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnEndOpen(IAsyncResult)

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnEndScheduleMessage(IAsyncResult)

在结束消息计划时引发事件。

OnEndSend(IAsyncResult)

执行结束发送操作。 此方法适用于内部使用,不能由用户在具体类中实现。

OnEndSendEventData(IAsyncResult)

执行结束发送事件数据操作。 此方法适用于内部使用,不能由用户在具体类中实现。

OnFaulted()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnOpen(TimeSpan)

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnOpened()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
OnSend(TrackingContext, IEnumerable<BrokeredMessage>, TimeSpan)

这样,具体实现就可以根据需要替代 (,) 以同步方式发送 messages 时应执行的操作。

Send(BrokeredMessage)

发送指定的中转消息。

SendAsync(BrokeredMessage)

异步发送指定的中转消息。

SendBatch(IEnumerable<BrokeredMessage>)

(发送一组中转消息用于批处理) 。

SendBatchAsync(IEnumerable<BrokeredMessage>)

异步发送一组中转消息 (进行批处理) 。

ThrowIfClosed()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
ThrowIfDisposed()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
ThrowIfDisposedOrImmutable()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
ThrowIfDisposedOrNotOpen()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)
ThrowIfFaulted()

MessageSender 类用于从服务总线发送消息。

(继承自 ClientEntity)

适用于