c# - 处理 NServiceBus 订阅消息时出错

Question

向我的应用程序添加日志记录(使用 log4net)后，它不再正确处理订阅消息并将它们放入错误队列。下面，一些 namespace 名称已更改以保护无辜者。

app.config

<?xml version="1.0"?>
<configuration>
<configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
    <section name="MsmqSubscriptionStorageConfig" type="NServiceBus.Config.MsmqSubscriptionStorageConfig, NServiceBus.Core" />
    <section name="Logging" type="NServiceBus.Config.Logging, NServiceBus.Core" />
    <section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler, log4net" />
</configSections>

<Logging Threshold="INFO" />

<log4net>
    <appender name="ConsoleAppender" type="log4net.Appender.ConsoleAppender">
        <layout type="log4net.Layout.PatternLayout">
            <param name="ConversionPattern" value="%d [%t] %-5p %c [%x] &lt;%X{auth}&gt; - %m%n"/>
        </layout>
    </appender>
    <appender name="EventLogAppender" type="log4net.Appender.EventLogAppender" >
        <layout type="log4net.Layout.PatternLayout">
            <param name="ConversionPattern" value="%d [%t] %-5p %c [%x] &lt;%X{auth}&gt; - %m%n"/>
        </layout>
    </appender>
    <appender name="TraceAppender" type="log4net.Appender.TraceAppender">
        <layout type="log4net.Layout.PatternLayout">
            <param name="ConversionPattern" value="%d [%t] %-5p %c [%x] &lt;%X{auth}&gt; - %m%n"/>
        </layout>
    </appender>
    <appender name="FileAppender" type="log4net.Appender.FileAppender">
        <file value="logfile.txt" />
        <appendToFile value="true" />
        <layout type="log4net.Layout.PatternLayout">
            <conversionPattern value="%date [%thread] %-5level %logger [%property{NDC}] - %message%newline" />
        </layout>
    </appender>
    <root>
        <level value="INFO"/>
        <appender-ref ref="ConsoleAppender"/>
        <appender-ref ref="FileAppender"/>
    </root>
</log4net>

<MsmqTransportConfig
  InputQueue="BankRequestDispatcherInputQueue_DEV2"
  ErrorQueue="error"
  NumberOfWorkerThreads="1"
  MaxRetries="5"
/>

<UnicastBusConfig ForwardReceivedMessagesTo="auditqueue">
    <MessageEndpointMappings>
        <add Messages="<assembly>.BankRequestBatchClosed,<assembly>" Endpoint="ScheduledBatchAgentInputQueue_DEV2" />
    </MessageEndpointMappings>
</UnicastBusConfig>

<MsmqSubscriptionStorageConfig Queue="BRDispatcher_DEV2_subscriptions" />

<!-- Neccessary for Fluent/NHibernate/SQLLite dlls -->
<startup useLegacyV2RuntimeActivationPolicy="true">
    <supportedRuntime version="v4.0"  sku=".NETFramework,Version=v4.0"/>
</startup>
<appSettings>
    <add key="TempRequestFileLocation" value="c:\temp\"/>
    <add key="KeepRequestFiles" value="true"/>
    <add key="Environment" value="TEST"/>
</appSettings>
</configuration>

我还将端点配置更改为:

namespace myNamespace.BRDispatcher
{
    /// <summary>
    /// Interface tells NServiceBus which roles to setup for this class. 
    /// </summary> 
    public class BRDEndpointConfig : IConfigureThisEndpoint, IWantCustomInitialization
    {
        #region Class References -1-
        /// <summary>
        /// Reference to Logger object.
        /// </summary>
        private static readonly ILog Logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
        #endregion
    public void Init()
    {
        NServiceBus.SetLoggingLibrary.Log4Net(log4net.Config.XmlConfigurator.Configure);

        Logger.Info("BankRequestDispatcher - Init()");

        NServiceBus.Configure.With()
            //.Log4Net()
          .DefaultBuilder()
          .XmlSerializer()
          .MsmqSubscriptionStorage()
          .MsmqTransport()
             .IsTransactional(true)
             .PurgeOnStartup(false)
          .UnicastBus()
             .ImpersonateSender(false)
             .LoadMessageHandlers()
          .CreateBus()
          .Start();

        Logger.Info("BankRequestDispatcher - Init() Complete");
    }
}
}

当它启动时，收到的任何订阅消息都会被转储到错误队列中，我在日志中看到了这一点:

2012-02-22 17:02:48,013 [Worker.8] ERROR NServiceBus.Unicast.Transport.Msmq.MsmqTransport [(null)] - Message has failed the maximum number of times allowed, ID=94b95c71-896f-4991-b3ba-9d2068a68c63\81504.

Answer 1

这是由于 RC4 中的一个错误，请尝试使用
RC5，看看是否能解决问题。