영업: 1-800-867-1380

MessageReceiver 클래스

메시지 컨테이너에서 메시지를 수신하고 이를 승인합니다.

네임스페이스:  Microsoft.ServiceBus.Messaging
어셈블리:  Microsoft.ServiceBus(Microsoft.ServiceBus.dll)

public abstract class MessageReceiver : MessageClientEntity

MessageReceiver 유형에서 다음 멤버를 표시합니다.

  이름설명
공용 속성BatchFlushInterval일괄 플러시 간격을 가져옵니다.
보호된 속성BatchingEnabled일괄 처리가 사용되도록 설정되었는지 여부를 나타내는 값을 가져옵니다.
공용 속성IsClosed (ClientEntity에서 상속됨)
공용 속성LastPeekedSequenceNumber마지막으로 본 메시지의 시퀀스 번호를 가져오거나 설정합니다.
공용 속성Mode메시지 수신 모드를 가져옵니다.
공용 속성PathMessagingFactory 기본 주소를 기준으로 한 큐나 항목의 경로를 가져옵니다.
공용 속성PrefetchCount메시지 수신자가 동시에 요청할 수 있는 메시지 수를 가져오거나 설정합니다.
보호된 속성ReceiverStartTime
공용 속성RetryPolicy (ClientEntity에서 상속됨)
보호된 속성StartOffset
보호된 속성ThisLock (ClientEntity에서 상속됨)
맨 위로 이동

  이름설명
공용 메서드Abandon(Guid)메시지를 삭제하고 메시지 잠금 소유권을 포기합니다.
공용 메서드Abandon(Guid, IDictionary<(Of <<'(String, Object>)>>))메시지를 삭제하고 메시지 잠금 소유권을 포기합니다.
공용 메서드AbandonAsync(Guid)메시지를 비동기적으로 삭제하고 메시지 잠금 소유권을 포기합니다.
공용 메서드AbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))메시지를 비동기적으로 삭제하고 메시지 잠금 소유권을 포기합니다.
공용 메서드AbortPerforms abort functionality on the messaging entity. (ClientEntity에서 상속됨)
공용 메서드BeginAbandon(Guid, AsyncCallback, Object)메시지를 중단하고 잠금을 해제하는 비동기 작업을 시작합니다.
공용 메서드BeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)메시지를 중단하고 잠금을 해제하는 비동기 작업을 시작합니다.
공용 메서드BeginClose메시지 클라이언트 엔터티를 닫는 비동기 작업을 시작합니다. (MessageClientEntity에서 상속됨)
공용 메서드BeginComplete메시지 수신을 완료하는 비동기 작업을 시작합니다.
공용 메서드BeginCompleteBatch메시지 일괄 처리를 완료하는 비동기 작업을 시작합니다.
공용 메서드BeginDeadLetter(Guid, AsyncCallback, Object)메시지를 배달 못한 편지 큐로 이동하는 비동기 작업을 시작합니다.
공용 메서드BeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)메시지를 배달 못한 편지 큐로 이동하는 비동기 작업을 시작합니다.
공용 메서드BeginDeadLetter(Guid, String, String, AsyncCallback, Object)메시지를 배달 못한 편지 큐로 이동하는 비동기 작업을 시작합니다.
공용 메서드BeginDefer(Guid, AsyncCallback, Object)메시지 수신을 일시 중단하는 비동기 작업을 시작합니다.
공용 메서드BeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), 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<(Of <<'(Int64>)>>), AsyncCallback, Object)일괄 메시지를 받는 비동기 작업을 시작합니다.
공용 메서드BeginReceiveBatch(Int32, AsyncCallback, Object)일괄 메시지를 받는 비동기 작업을 시작합니다.
공용 메서드BeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)일괄 메시지를 받는 비동기 작업을 시작합니다.
공용 메서드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에서 상속됨)
공용 메서드Complete메시지에 대한 수신 작업을 완료합니다.
공용 메서드CompleteAsync메시지 수신 작업을 비동기적으로 완료합니다.
공용 메서드CompleteBatch일괄 메시지에 대한 수신 작업을 완료합니다.
공용 메서드CompleteBatchAsync일괄 메시지에 대한 수신 작업을 비동기적으로 완료합니다.
공용 메서드DeadLetter(Guid)배달하지 못한 메시지를 배달 못한 편지 큐로 이동합니다.
공용 메서드DeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))배달하지 못한 메시지를 배달 못한 편지 큐로 이동합니다.
공용 메서드DeadLetter(Guid, String, String)배달하지 못한 메시지를 배달 못한 편지 큐로 이동합니다.
공용 메서드DeadLetterAsync(Guid)배달 못한 편지 큐로 배달하지 못한 메시지를 비동기적으로 이동합니다.
공용 메서드DeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))배달 못한 편지 큐로 배달하지 못한 메시지를 비동기적으로 이동합니다.
공용 메서드DeadLetterAsync(Guid, String, String)배달 못한 편지 큐로 배달하지 못한 메시지를 비동기적으로 이동합니다.
공용 메서드Defer(Guid)수신자가 메시지에 대한 처리를 연기하기를 원함을 나타냅니다.
공용 메서드Defer(Guid, IDictionary<(Of <<'(String, Object>)>>))수신자가 메시지에 대한 처리를 연기하기를 원함을 나타냅니다.
공용 메서드DeferAsync(Guid)메시지 처리 작업을 비동기적으로 연기합니다.
공용 메서드DeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))메시지 처리 작업을 비동기적으로 연기합니다.
공용 메서드EndAbandon메시지를 중단하고 잠금을 해제하는 비동기 작업을 종료합니다.
공용 메서드EndClose메시지 클라이언트 엔터티를 닫는 비동기 작업을 마칩니다. (MessageClientEntity에서 상속됨)
공용 메서드EndComplete메시지 수신을 완료하는 비동기 작업을 종료합니다.
공용 메서드EndCompleteBatch일괄 메시지 수신을 완료하는 비동기 작업을 종료합니다.
공용 메서드EndDeadLetter메시지를 배달 못한 편지 큐로 이동하는 비동기 작업을 종료합니다.
공용 메서드EndDefer메시지 수신을 연기하는 비동기 작업을 종료합니다.
공용 메서드EndPeek메시지를 보는 비동기 작업을 종료합니다.
공용 메서드EndPeekBatch일괄 메시지를 보는 비동기 작업을 종료합니다.
공용 메서드EndReceive메시지를 수신하는 비동기 작업을 종료합니다.
공용 메서드EndReceiveBatch일괄 메시지를 받는 비동기 작업을 종료합니다.
공용 메서드Equals (Object에서 상속됨)
보호된 메서드FaultFor internal use only. Do not inherit from this class. (ClientEntity에서 상속됨)
보호된 메서드Finalize (Object에서 상속됨)
공용 메서드GetHashCode (Object에서 상속됨)
보호된 메서드정적 멤버GetLockToken메시지에 바인딩된 잠금 토큰을 가져옵니다.
보호된 메서드정적 멤버GetLockTokens지정된 메시지 컬렉션에서 잠금 토큰 컬렉션을 가져옵니다.
공용 메서드GetType (Object에서 상속됨)
보호된 메서드MemberwiseClone (Object에서 상속됨)
보호된 메서드OnAbandonAbandon 작업 호출 시 실행합니다.
보호된 메서드OnAbort (ClientEntity에서 상속됨)
보호된 메서드OnBeginAbandonOnAbandon 또는 BeginAbandon 작업 호출 시 실행합니다.
보호된 메서드OnBeginClose (ClientEntity에서 상속됨)
보호된 메서드OnBeginComplete(TrackingContext, IEnumerable<(Of <<'(ArraySegment<(Of <<'(Byte>)>>)>)>>), Boolean, TimeSpan, AsyncCallback, Object)
보호된 메서드OnBeginComplete(TrackingContext, IEnumerable<(Of <<'(Guid>)>>), Boolean, TimeSpan, AsyncCallback, Object)OnComplete 또는 BeginComplete 작업 호출 시 실행합니다.
보호된 메서드OnBeginDeadLetterOnDeadLetter 또는 BeginDeadLetter 작업 호출 시 실행합니다.
보호된 메서드OnBeginDeferOnDefer 또는 BeginDefer 작업 호출 시 실행합니다.
보호된 메서드OnBeginOpen (ClientEntity에서 상속됨)
보호된 메서드OnBeginPeekBeginPeek 작업 호출 시 실행합니다.
보호된 메서드OnBeginRenewMessageLocks잠금 메시지에 대한 OnBegin 작업 호출 시 실행합니다.
보호된 메서드OnBeginTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, AsyncCallback, Object)OnTryReceive 또는 BeginTryReceive 작업 호출 시 실행합니다.
보호된 메서드OnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)OnTryReceive 또는 BeginTryReceive 작업 호출 시 실행합니다.
보호된 메서드OnBeginTryReceive2OnTryReceive 또는 BeginTryReceive 작업 호출 시 실행합니다.
보호된 메서드OnBeginTryReceiveEventData
보호된 메서드OnClose (ClientEntity에서 상속됨)
보호된 메서드OnClosed (ClientEntity에서 상속됨)
보호된 메서드OnCompleteComplete 작업 호출 시 실행합니다.
보호된 메서드OnDeadLetterDeadLetter 작업 호출 시 실행합니다.
보호된 메서드OnDeferDefer 작업 호출 시 실행합니다.
보호된 메서드OnEndAbandon중단 종료 동작을 실행합니다.
보호된 메서드OnEndClose (ClientEntity에서 상속됨)
보호된 메서드OnEndComplete완료 종료 동작을 실행합니다.
보호된 메서드OnEndDeadLetter배달 못한 편지 큐로 이동 종료 동작을 실행합니다.
보호된 메서드OnEndDefer연기 종료 동작을 실행합니다.
보호된 메서드OnEndOpen (ClientEntity에서 상속됨)
보호된 메서드OnEndPeekEndPeek 작업을 실행합니다.
보호된 메서드OnEndRenewMessageLocks메시지 잠금을 위해 EndRenew 작업을 실행합니다.
보호된 메서드OnEndTryReceive수신 시도 종료 동작을 실행합니다.
보호된 메서드OnEndTryReceive2수신 시도 종료 동작을 실행합니다.
보호된 메서드OnEndTryReceiveEventData
보호된 메서드OnFaulted (ClientEntity에서 상속됨)
공용 메서드OnMessage이벤트 구동 메시지 펌프의 메시지를 처리합니다.
공용 메서드OnMessageAsync이벤트 구동 메시지 펌프의 메시지를 비동기적으로 처리합니다.
보호된 메서드OnOpen (ClientEntity에서 상속됨)
보호된 메서드OnOpened (ClientEntity에서 상속됨)
보호된 메서드OnPeekPeek 작업 호출 시 실행합니다.
보호된 메서드OnRenewMessageLocks잠금 메시지에 대해 Renew 작업을 실행합니다.
보호된 메서드OnTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)TryReceive 작업 호출 시 실행합니다.
보호된 메서드OnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)TryReceive 작업 호출 시 실행합니다.
공용 메서드Peek()()()()수신자나 메시지 원본의 상태를 변경하지 않고 다음 메시지를 읽습니다.
공용 메서드Peek(Int64)수신자나 메시지 원본의 상태를 변경하지 않고 다음 메시지를 읽습니다.
공용 메서드PeekAsync()()()()수신자나 메시지 원본의 상태를 변경하지 않고 다음 메시지를 비동기적으로 읽습니다.
공용 메서드PeekAsync(Int64)수신자나 메시지 원본의 상태를 변경하지 않고 다음 메시지를 비동기적으로 읽습니다.
공용 메서드PeekBatch(Int32)수신자나 메시지 원본의 상태를 변경하지 않고 다음 일괄 메시지를 읽습니다.
공용 메서드PeekBatch(Int64, Int32)수신자나 메시지 원본의 상태를 변경하지 않고 다음 일괄 메시지를 읽습니다.
공용 메서드PeekBatchAsync(Int32)수신자나 메시지 원본의 상태를 변경하지 않고 다음 일괄 메시지를 비동기적으로 읽습니다.
공용 메서드PeekBatchAsync(Int64, Int32)수신자나 메시지 원본의 상태를 변경하지 않고 다음 일괄 메시지를 비동기적으로 읽습니다.
공용 메서드Receive()()()()현재 큐나 항목에서 BrokeredMessage를 수신합니다.
공용 메서드Receive(Int64)현재 큐나 항목에서 메시지를 수신합니다.
공용 메서드Receive(TimeSpan)현재 큐나 항목에서 BrokeredMessage를 수신합니다.
공용 메서드ReceiveAsync()()()()현재 큐나 항목에서 메시지를 비동기적으로 수신합니다.
공용 메서드ReceiveAsync(Int64)현재 큐나 항목에서 메시지를 비동기적으로 수신합니다.
공용 메서드ReceiveAsync(TimeSpan)현재 큐나 항목에서 메시지를 비동기적으로 수신합니다.
공용 메서드ReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))일괄 메시지를 받습니다.
공용 메서드ReceiveBatch(Int32)일괄 메시지를 받습니다.
공용 메서드ReceiveBatch(Int32, TimeSpan)일괄 메시지를 받습니다.
공용 메서드ReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))일괄 메시지를 비동기적으로 수신합니다.
공용 메서드ReceiveBatchAsync(Int32)일괄 메시지를 비동기적으로 수신합니다.
공용 메서드ReceiveBatchAsync(Int32, TimeSpan)일괄 메시지를 비동기적으로 수신합니다.
보호된 메서드ThrowIfClosed (ClientEntity에서 상속됨)
보호된 메서드ThrowIfDisposed (ClientEntity에서 상속됨)
보호된 메서드ThrowIfDisposedOrImmutable (ClientEntity에서 상속됨)
보호된 메서드ThrowIfDisposedOrNotOpen (ClientEntity에서 상속됨)
보호된 메서드ThrowIfFaulted (ClientEntity에서 상속됨)
공용 메서드ToString (Object에서 상속됨)
맨 위로 이동

Although you can use the QueueClient class to send and receive messages without creating a MessageReceiver object, you can also use MessageSender and MessageReceiver to create a sender and receiver on an entity. However, note that you can only use a MessageReceiver to receive messages from a queue or subscription; you cannot receive messages or listen for messages from a topic. Similarly, you can only use a MessageSender to send messages to a queue or topic; you cannot send messages to a subscription. Note that the default message receive mode is PeekLock, which ensures reliable message receiving.

When you create a MessageReceiver for subscriptions, the entityPath parameter is of the form topicPath/subscriptions/subscriptionName.

The following example receives a message from the queue created in the MessageSender example:

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

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

MessageReceiver myMessageReceiver = factory.CreateMessageReceiver(queueName);

BrokeredMessage message;
while ((message = myMessageReceiver.Receive(new TimeSpan(hours: 0, minutes: 1, seconds: 5))) != null)
{
    Console.WriteLine(
    string.Format(
    "Message received: Id = {0}, Body = {1}", message.MessageId, message.GetBody<string>()));
    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.

이 정보가 도움이 되었습니까?
(1500자 남음)
의견을 주셔서 감사합니다.

커뮤니티 추가 항목

추가
표시:
© 2014 Microsoft