此页面有用吗?
您对此内容的反馈非常重要。 请告诉我们您的想法。
更多反馈?
1500 个剩余字符
QueueClient 类
Collapse the table of content
Expand the table of content

QueueClient 类

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

代表队列客户端对象。

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

public abstract class QueueClient : MessageClientEntity

QueueClient 类型公开以下成员。

  名称说明
公共属性IsClosed (从 ClientEntity 继承。)
公共属性MessagingFactory获取或设置消息工厂。
公共属性Mode获取处理收到的消息时的消息接收模式。
公共属性Path获取或设置队列的完整路径名称。
公共属性PrefetchCount获取或设置队列接收器可同时请求的消息数。
公共属性RetryPolicy (从 ClientEntity 继承。)
受保护属性ThisLock (从 ClientEntity 继承。)
页首

  名称说明
公共方法Abandon(Guid)丢弃消息并放弃消息锁所有权。
公共方法Abandon(Guid, IDictionary<String, Object>)丢弃消息并放弃消息锁所有权。
公共方法AbandonAsync(Guid)异步丢弃消息并放弃消息锁所有权。
公共方法AbandonAsync(Guid, IDictionary<String, Object>)异步丢弃消息并放弃消息锁所有权。
公共方法Abort对消息传送实体执行中止功能。 (从 ClientEntity 继承。)
公共方法AcceptMessageSession()接受一个消息会话,该会话允许将相关消息分组以便在单个事务中处理。
公共方法AcceptMessageSession(String)接受一个消息会话,该会话允许将相关消息分组,以便使用给定的会话标识符在单个事务中处理。
公共方法AcceptMessageSession(TimeSpan)接受一个消息会话,该会话允许将相关消息分组,以便使用指定的服务器等待时间在单个事务中处理。
公共方法AcceptMessageSession(String, TimeSpan)接受一个消息会话,该会话允许将相关消息分组,以便使用给定的会话标识符和等待时间在单个事务中处理。
公共方法AcceptMessageSessionAsync()异步接受一个消息会话,该会话允许将相关消息分组以便在单个事务中处理。
公共方法AcceptMessageSessionAsync(String)异步接受一个消息会话,该会话允许将相关消息分组,以便使用给定的会话标识符在单个事务中处理。
公共方法AcceptMessageSessionAsync(TimeSpan)异步接受一个消息会话,该会话允许将相关消息分组,以便使用指定的服务器等待时间在单个事务中处理。
公共方法AcceptMessageSessionAsync(String, TimeSpan)异步接受一个消息会话,该会话允许将相关消息分组,以便使用给定的会话标识符和等待时间在单个事务中处理。
公共方法BeginAbandon(Guid, AsyncCallback, Object)开始用于放弃消息及其锁的异步操作。
公共方法BeginAbandon(Guid, IDictionary<String, Object>, AsyncCallback, Object)开始用于放弃消息及其锁的异步操作。
公共方法BeginAcceptMessageSession(AsyncCallback, Object)开始用于接受消息会话的异步操作。
公共方法BeginAcceptMessageSession(String, AsyncCallback, Object)开始用于接受消息会话的异步操作。
公共方法BeginAcceptMessageSession(TimeSpan, AsyncCallback, Object)开始用于接受消息会话的异步操作。
公共方法BeginAcceptMessageSession(String, TimeSpan, AsyncCallback, Object)开始用于接受消息会话的异步操作。
公共方法BeginClose开始用于关闭消息客户端实体的异步操作。 (从 MessageClientEntity 继承。)
公共方法BeginComplete开始用于完成消息处理的异步操作。
公共方法BeginCompleteBatch开始用于完成消息批处理的异步操作。
公共方法BeginDeadLetter(Guid, AsyncCallback, Object)开始用于将消息移至死信队列的异步操作。
公共方法BeginDeadLetter(Guid, IDictionary<String, Object>, AsyncCallback, Object)开始用于将消息移至死信队列的异步操作。
公共方法BeginDeadLetter(Guid, String, String, AsyncCallback, Object)开始用于将消息移至死信队列的异步操作。
公共方法BeginDefer(Guid, AsyncCallback, Object)开始用于挂起消息处理的异步操作。
公共方法BeginDefer(Guid, IDictionary<String, Object>, AsyncCallback, Object)开始用于挂起消息处理的异步操作。
公共方法BeginGetMessageSessions(AsyncCallback, Object)开始用于获取消息会话的异步操作。
公共方法BeginGetMessageSessions(DateTime, AsyncCallback, Object)开始用于获取消息会话的异步操作。
公共方法BeginPeek(AsyncCallback, Object)开始用于扫视消息的异步操作。
公共方法BeginPeek(Int64, AsyncCallback, Object)开始用于扫视消息的异步操作。
公共方法BeginPeekBatch(Int32, AsyncCallback, Object)开始用于扫视消息批的异步操作。
公共方法BeginPeekBatch(Int64, Int32, AsyncCallback, Object)开始用于扫视消息批的异步操作。
公共方法BeginReceive(AsyncCallback, Object)开始用于接收消息的异步操作。
公共方法BeginReceive(Int64, AsyncCallback, Object)开始用于接收消息的异步操作。
公共方法BeginReceive(TimeSpan, AsyncCallback, Object)开始用于接收消息的异步操作。
公共方法BeginReceiveBatch(IEnumerable<Int64>, AsyncCallback, Object)开始用于接收消息批的异步操作。
公共方法BeginReceiveBatch(Int32, AsyncCallback, Object)开始用于接收消息批的异步操作。
公共方法BeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)开始用于接收消息批的异步操作。
公共方法BeginSend开始用于发送消息的异步操作。
公共方法BeginSendBatch开始用于发送消息批的异步操作。
公共方法Close向 Service Bus 发送清除消息,指出已完成对实体的使用。 (从 ClientEntity 继承。)
公共方法CloseAsync向 Service Bus 异步发送清除消息,指出已完成对实体的使用。 (从 ClientEntity 继承。)
公共方法Complete完成消息处理。
公共方法CompleteAsync异步完成消息处理。
公共方法CompleteBatch完成消息批处理。
公共方法CompleteBatchAsync异步完成消息批处理。
公共方法静态成员Create(String)使用指定的路径创建 QueueClient 的新副本。
公共方法静态成员Create(String, ReceiveMode)使用指定的路径和模式创建 QueueClient 的新副本。
公共方法静态成员CreateFromConnectionString(String)
公共方法静态成员CreateFromConnectionString(String, ReceiveMode)
公共方法静态成员CreateFromConnectionString(String, String)使用指定的路径从连接字符串创建 QueueClient 的新副本。
公共方法静态成员CreateFromConnectionString(String, String, ReceiveMode)使用指定的路径和模式从连接字符串创建 QueueClient 的新副本。
公共方法DeadLetter(Guid)将未传递的消息移至死信队列。
公共方法DeadLetter(Guid, IDictionary<String, Object>)将未传递的消息移至死信队列。
公共方法DeadLetter(Guid, String, String)将未传递的消息移至死信队列。
公共方法DeadLetterAsync(Guid)将未传递的消息异步移动到死信队列。
公共方法DeadLetterAsync(Guid, IDictionary<String, Object>)将未传递的消息异步移动到死信队列。
公共方法DeadLetterAsync(Guid, String, String)将未传递的消息异步移动到死信队列。
公共方法Defer(Guid)挂起消息处理。
公共方法Defer(Guid, IDictionary<String, Object>)挂起消息处理。
公共方法DeferAsync(Guid)异步挂起消息处理。
公共方法DeferAsync(Guid, IDictionary<String, Object>)异步挂起消息处理。
公共方法EndAbandon完成用于放弃消息及其锁的异步操作。
公共方法EndAcceptMessageSession完成用于接受消息会话的异步操作,该会话允许将相关消息分组以便在单个事务中处理。
公共方法EndClose完成用于关闭消息客户端实体的异步操作。 (从 MessageClientEntity 继承。)
公共方法EndComplete完成用于完成消息处理的异步操作。
公共方法EndCompleteBatch完成用于完成消息批处理的异步操作。
公共方法EndDeadLetter完成用于将消息移至死信队列的异步操作。
公共方法EndDefer完成用于挂起消息处理的异步操作。
公共方法EndGetMessageSessions结束用于获取消息会话的异步操作。
公共方法EndPeek结束用于扫视消息的异步操作。
公共方法EndPeekBatch结束用于扫视消息批的异步操作。
公共方法EndReceive完成用于接收消息的异步操作。
公共方法EndReceiveBatch完成用于接收消息批的异步操作。
公共方法EndSend完成用于发送消息的异步操作。
公共方法EndSendBatch完成用于发送消息批的异步操作。
公共方法Equals (从 Object 继承。)
受保护方法Fault仅供内部使用。请勿从此类继承。 (从 ClientEntity 继承。)
受保护方法Finalize (从 Object 继承。)
公共方法静态成员FormatDeadLetterPath从指定的死信队列路径构建格式名称。
公共方法静态成员FormatTransferDeadLetterPath
公共方法GetHashCode (从 Object 继承。)
公共方法GetMessageSessions()获取消息会话,从而使你可以浏览队列中的会话。
公共方法GetMessageSessions(DateTime)检索自 lastUpdatedTime 以来已更新了会话状态的所有消息会话。
公共方法GetMessageSessionsAsync()异步获取消息会话,从而使你可以浏览队列中的会话。
公共方法GetMessageSessionsAsync(DateTime)异步检索自 lastUpdatedTime 以来已更新了会话状态的所有消息会话。
公共方法GetType (从 Object 继承。)
受保护方法MemberwiseClone (从 Object 继承。)
受保护方法OnAbort在调用 Abort 事件时执行。 (覆盖 ClientEntity.OnAbort()。)
受保护方法OnBeginAcceptMessageSession在调用 BeginAcceptMessageSession 操作时执行。
受保护方法OnBeginClose调用 Close 操作时执行。 (覆盖 ClientEntity.OnBeginClose(TimeSpan, AsyncCallback, Object)。)
受保护方法OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)执行“开始创建接收器”操作。
受保护方法OnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)执行“开始创建接收器”操作。
受保护方法OnBeginCreateSender执行“开始创建发送器”操作。
受保护方法OnBeginGetMessageSessions执行 BeginGetMessageSessions 操作。
受保护方法OnBeginOpen (从 ClientEntity 继承。)
受保护方法OnClose在调用 Close 操作时执行。 (覆盖 ClientEntity.OnClose(TimeSpan)。)
受保护方法OnClosed (从 ClientEntity 继承。)
受保护方法OnEndAcceptMessageSession在调用 EndAcceptMessageSession 操作时执行。
受保护方法OnEndClose执行“结束关闭”操作。 (覆盖 ClientEntity.OnEndClose(IAsyncResult)。)
受保护方法OnEndCreateReceiver执行“结束创建接收器”操作。
受保护方法OnEndCreateSender执行“结束创建发送器”操作。
受保护方法OnEndGetMessageSessions执行“结束获取消息”操作。
受保护方法OnEndOpen (从 ClientEntity 继承。)
受保护方法OnFaulted (从 ClientEntity 继承。)
公共方法OnMessage(Action<BrokeredMessage>)在事件驱动的消息泵中处理消息。
公共方法OnMessage(Action<BrokeredMessage>, OnMessageOptions)使用给定的一组 OnMessageOptions 选项,在事件驱动的消息泵中处理消息。
公共方法OnMessageAsync(Func<BrokeredMessage, Task>)异步处理消息。
公共方法OnMessageAsync(Func<BrokeredMessage, Task>, OnMessageOptions)异步处理消息。
受保护方法OnOpen (从 ClientEntity 继承。)
受保护方法OnOpened (从 ClientEntity 继承。)
公共方法Peek()返回,但不删除队列中的第一个消息。
公共方法Peek(Int64)返回,但不删除队列中的第一个消息。
公共方法PeekAsync()异步返回,但不删除队列中的第一个消息。
公共方法PeekAsync(Int64)异步返回,但不删除队列中的第一个消息。
公共方法PeekBatch(Int32)扫视消息批。
公共方法PeekBatch(Int64, Int32)扫视消息批。
公共方法PeekBatchAsync(Int32)异步扫视消息批。
公共方法PeekBatchAsync(Int64, Int32)异步扫视消息批。
公共方法Receive()使用 InternalReceiver 接收消息。
公共方法Receive(Int64)使用 InternalReceiver 接收消息。
公共方法Receive(TimeSpan)使用 InternalReceiver 接收消息。
公共方法ReceiveAsync()使用 InternalReceiver 来异步接收消息。
公共方法ReceiveAsync(Int64)使用 InternalReceiver 来异步接收消息。
公共方法ReceiveAsync(TimeSpan)使用 InternalReceiver 来异步接收消息。
公共方法ReceiveBatch(IEnumerable<Int64>)接收消息批。
公共方法ReceiveBatch(Int32)接收消息批。
公共方法ReceiveBatch(Int32, TimeSpan)接收消息批。
公共方法ReceiveBatchAsync(IEnumerable<Int64>)异步接收消息批。
公共方法ReceiveBatchAsync(Int32)异步接收消息批。
公共方法ReceiveBatchAsync(Int32, TimeSpan)异步接收消息批。
公共方法RegisterSessionHandler(Type)注册具有特定类型的会话处理程序。
公共方法RegisterSessionHandler(Type, SessionHandlerOptions)注册具有特定类型和处理程序选项的会话处理程序。
公共方法RegisterSessionHandlerAsync(Type)异步注册具有特定类型的会话处理程序。
公共方法RegisterSessionHandlerAsync(Type, SessionHandlerOptions)异步注册具有特定类型和处理程序选项的会话处理程序。
公共方法RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)使用指定的选项注册消息会话处理程序工厂。
公共方法RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)使用指定的选项注册消息会话处理程序工厂。
公共方法RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)异步注册消息会话处理程序工厂。
公共方法RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)异步注册消息会话处理程序工厂。
公共方法Send使用 InternalSender 发送消息。
公共方法SendAsync使用 InternalSender 来异步发送消息。
公共方法SendBatch发送一组中转消息(用于批处理)。
公共方法SendBatchAsync异步发送一组中转消息(用于批处理)。
受保护方法ThrowIfClosed (从 ClientEntity 继承。)
受保护方法ThrowIfDisposed (从 ClientEntity 继承。)
受保护方法ThrowIfDisposedOrImmutable (从 ClientEntity 继承。)
受保护方法ThrowIfDisposedOrNotOpen (从 ClientEntity 继承。)
受保护方法ThrowIfFaulted (从 ClientEntity 继承。)
公共方法ToString (从 Object 继承。)
页首

This class is mainly used for Service Bus run-time operations, such as sending and receiving messages.

This abstract class is not meant to be inherited, so protected members of this class should be ignored.

// Create the MessagingFactory
     MessagingFactory factory = 
     MessagingFactory.Create(myServiceBusNamespaceUri, SharedSecretTokenProvider.CreateSharedSecretTokenProvider(issuerName, issuerKey));
    
     //********************************************************************************
     //                          Sending messages to a Queue
     //********************************************************************************
    
     // Create queue client
     QueueClient myQueueClient = factory.CreateQueueClient("myQueue");
    
     // Send messages
     List <object>; Issues = new List <object>();
     foreach (var issue in Issues)
     {
        myQueueClient.Send(new BrokeredMessage(issue));
     }
    
     // ... Recieve messages
     for (int count = 0; count < MsgCount; count++)
     {
         var message = myQueueClient.Receive();
         message.Complete();
     }

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

社区附加资源

添加
显示:
© 2015 Microsoft