Message forwarding

Message forwarding

Component: NServiceBus |
NuGet Package

Standard support for version 5.x of NServiceBus has expired. For more information see our Support Policy.

Use this feature to forward successfully processed messages from an endpoint to a specific destination endpoint. Forwarding messages is particularly useful in complex upgrade scenarios when the old version and new version of a particular endpoint are running side-by-side.

Auditing vs. Forwarding

Auditing and Forwarding are very similar. Both send a copy of the processed message to another queue. The main difference is the intended usage scenarios.

Auditing is used for collecting information on what is happening in the system. The audited message is enriched with additional information regarding the processing of it. Forwarding would send a copy of the processed message without the additional auditing information.

Some of the audit message headers are available

Configuring Message Forwarding

Using app.config

Copy code|Copy usings|Edit

<configuration>
  <configSections>
    <section name="UnicastBusConfig"
             type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core"/>
  </configSections>
  <UnicastBusConfig ForwardReceivedMessagesTo="destinationQueue@machine" />
</configuration>

Using IProvideConfiguration

Copy code|Copy usings|Edit

class ProvideConfigurationForMessageForwarding :
    IProvideConfiguration<UnicastBusConfig>
{
    public UnicastBusConfig GetConfiguration()
    {
        return new UnicastBusConfig
        {
            ForwardReceivedMessagesTo = "destinationQueue@machine"
        };
    }
}

Using IConfigurationSource

Copy code|Copy usings|Edit

public class ConfigurationSource :
    IConfigurationSource
{
    public T GetConfiguration<T>() where T : class, new()
    {
        if (typeof(T) == typeof(UnicastBusConfig))
        {
            var config = new UnicastBusConfig
            {
                ForwardReceivedMessagesTo = "destinationQueue@machine"
            };

            return config as T;
        }

        // Respect app.config for other sections not defined in this method
        return ConfigurationManager.GetSection(typeof(T).Name) as T;
    }
}

Initialize the Configuration Source as follows:

Copy code|Copy usings|Edit

busConfiguration.CustomConfigurationSource(new ConfigurationSource());

Forwarding a message from the handler

Individual messages can be forwarded directly from the handler:

Copy code|Copy usings|Edit

bus.ForwardCurrentMessageTo("destinationQueue@machine");

Auditing vs. Forwarding

Configuring Message Forwarding

Using app.config

Using IProvideConfiguration

Using IConfigurationSource

Forwarding a message from the handler

Related Articles