I’m setting up a router to take messages from an AzureStorageQueue Transport & forward to a RabbitMQ transport. I’m defining the router interface for the AzureStorageQueueTransport as such:
routerConfig.AddInterface<AzureStorageQueueTransport>("AzureStorageQueue", t =>
{
t.ConnectionString(_settings.CloudBusSettings.TransportConnectionString);
t.SerializeMessageWrapperWith<NewtonsoftSerializer>();
});
However, upon calling router.Start()
I get an error from NServiceBus: “Use ‘endpointConfiguration.UseSerialization();’ to select a serializer.” The docs for AzureStorageQueueTransport says that an explicit serialization definition is required. However, I don’t see a way to do this with the provided object in the lambda (t
in the above code block). I get the same error with or without using the SerializeMessageWrapperWith<>();
function. Is there a way to define the serializer so I can use the AzureStorageQueueTransport with the Router?