특정 유형의 예외에 대한 Nsb : SLR + 오류 대기열 무시 기능

Question

특정 유형의 예외에 대한 논리 처리 예외를 구현하기위한 중앙 위치를 갖고 싶습니다. 특정 예외 유형이 발생하면

, 나는 내부 구성에 따라 다음 중 하나를 실행할 수 있도록하고 싶습니다 : 더 두 번째 수준 재시도없이 즉시 큐 에러

• 메시지 보내기;
• 메시지를 숨기고 처리 대기열 또는 오류 대기열로 보내지 않습니다. NServiceBus error handling

  그래서 어떻게 2 케이스를 구현할 수 :

나는 우리가 TimeSpan.MinValue을 반환하는 경우 메시지가 오류 큐에 넣어 것처럼, 첫 번째 경우 있지만 두 번째되지 하나를 커버이 주제를 발견했습니다? 두 클래스 모두 한 곳에서 하나의 클래스로 구현하는 것이 더 좋습니다.

Answer 1

NServiceBus 버전 6 이전에는 IManageMessageFailures을 사용하여 메시지 오류를 관리 할 수있었습니다. 첫 번째 수준의 재 시도가 시도 된 후에 메시지를 정상적으로 처리 할 수없는 경우 직렬화 예외 또는 처리중인 문제와 관련이있는 경우를 처리 할 수 ​​있습니다.

다음은 특정 유형의 예외를 무시하거나 다른 오류가있는 오류 메시지를 오류 대기열로 다시 보내는 맞춤 FaultManager을 구현하는 방법입니다. 1 단계 퇴역은 여전히 ​​발생하며 2 단계 재 시도가 아니라 1 단계 퇴역이 계속 발생합니다.

public class IssueOrder : ICommand 
{ 
    public bool NotFound { get; set; } 
    public bool HasFaulted { get; set; } 
} 

public class OrderHandler : IHandleMessages<IssueOrder> 
{ 
    public void Handle(IssueOrder message) 
    { 
     if(message.NotFound) 
      throw new OrderNotFoundException(); 

     if(message.HasFaulted) 
      throw new ApplicationException(); 
    } 
} 

public class OrderNotFoundException : Exception 
{ 
} 

public class CustomFaultManager : IManageMessageFailures 
{ 
    private ISendMessages sender; 
    private MessageForwardingInCaseOfFaultConfig config; 
    private BusNotifications notifications; 
    private static ILog Logger = LogManager.GetLogger<CustomFaultManager>(); 

    public CustomFaultManager(ISendMessages sender, IProvideConfiguration<MessageForwardingInCaseOfFaultConfig> config) 
    { 
     this.sender = sender; 
     this.config = config.GetConfiguration(); 
    } 

    public void SerializationFailedForMessage(TransportMessage message, Exception e) 
    { 
    } 

    public void ProcessingAlwaysFailsForMessage(TransportMessage message, Exception e) 
    { 
     if (e is OrderNotFoundException) 
     { 
      //Ignore the exception; 
      Logger.WarnFormat("OrderNotFoundException was thrown. Ignoring the message Id {0}.", message.Id); 
     } 
     else 
     { 
      //Check if you have performed enough retries, ultimately send to error queue 
      SendToErrorQueue(message, e); 
     } 
    } 

    private void SendToErrorQueue(TransportMessage message, Exception ex) 
    { 
     message.TimeToBeReceived = TimeSpan.MaxValue; 
     sender.Send(message, new SendOptions(config.ErrorQueue)); 
     Logger.WarnFormat("Message {0} will was moved to the error queue.", message.Id); 
    } 

    public void Init(Address address) 
    { 
    } 
} 

그리고 사용자 정의 FaultManager를 등록 :

var config = new BusConfiguration(); 
//Other configuration code 
config.RegisterComponents(c => 
     { 
      c.ConfigureComponent<CustomFaultManager>(DependencyLifecycle.InstancePerCall); 
     }); 

는 그러나 NServiceBus의 버전 6에서 IManageMessageFailures 인터페이스가 지원되지 않습니다. 버전 번호 6의 새로운 Recoverability api을 사용하면 예외를 무시/무시할 수있는 직접적인 방법이 없으므로 더 나은 맞춤 설정이 가능합니다. 이를 위해 NServiceBU pipeline에 사용자 지정 동작이 필요하며 알려진 단계 중 하나 (예 : 메시지가 오류 큐로 이동되기 전에) 사이의 단계에서이를 실행해야합니다.