Getting Started
 NServiceBus
 Transports
 Persistence
 ServiceInsight
 ServicePulse
 ServiceControl
 Monitoring
 Previews
 Samples

Azure Storage Queues Transport Upgrade Version 7 to 8

Component: Azure Storage Queues Transport
This page targets a pre-release version. Pre-releases are subject to change and samples are not guaranteed to be fully functional.

Sanitization

In previous versions, the transport was responsible for sanitization of the queue names. That included:

  • Replacing invalid characters
  • Lowering the case
  • Shortening queue names exceeding the maximum allowed queue name length, using SHA1 or MD5

In Versions 8 and above, the transport is no longer performing sanitization by default. Instead, sanitization logic must be registered.

11-pre NServiceBus.Transport.AzureStorageQueues
Copy code|Copy usings|Edit
var transport = new AzureStorageQueueTransport("connection string")
{
    QueueNameSanitizer = queueName => queueName.Replace('.', '-')
};

endpointConfiguration.UseTransport(transport);
10.x NServiceBus.Transport.AzureStorageQueues
Copy code|Copy usings|Edit
var transport = endpointConfiguration.UseTransport<AzureStorageQueueTransport>();
transport.SanitizeQueueNamesWith(queueName => queueName.Replace('.', '-'));
9.x NServiceBus.Transport.AzureStorageQueues
Copy code|Copy usings|Edit
var transport = endpointConfiguration.UseTransport<AzureStorageQueueTransport>();
transport.SanitizeQueueNamesWith(queueName => queueName.Replace('.', '-'));
8.x NServiceBus.Azure.Transports.WindowsAzureStorageQueues
Copy code|Copy usings|Edit
var transport = endpointConfiguration.UseTransport<AzureStorageQueueTransport>();
transport.SanitizeQueueNamesWith(queueName => queueName.Replace('.', '-'));

Serialization is mandatory

In Versions 7 and below, the transport was setting the default serialization. In Versions 8 and above, the transport no longer sets the default serialization. Instead, it must be configured.

For backwards compatibility with the previous default serialization, NServiceBus.Newtonsoft.Json serializer must be used.

11-pre NServiceBus.Transport.AzureStorageQueues
Copy code|Copy usings|Edit
endpointConfiguration.UseSerialization<NewtonsoftSerializer>();
10.x NServiceBus.Transport.AzureStorageQueues
Copy code|Copy usings|Edit
endpointConfiguration.UseSerialization<NewtonsoftSerializer>();
9.x NServiceBus.Transport.AzureStorageQueues
Copy code|Copy usings|Edit
endpointConfiguration.UseSerialization<NewtonsoftSerializer>();
8.x NServiceBus.Azure.Transports.WindowsAzureStorageQueues
Copy code|Copy usings|Edit
endpointConfiguration.UseSerialization<NewtonsoftSerializer>();

Related Articles


Last modified

Feedback