Prerequisites
An environment variable named AzureServiceBus_ConnectionString
with the connection string for the Azure Service Bus namespace.
Code walk-through
This sample shows a basic two-endpoint scenario exchanging messages with each other so that:
Endpoint1
sends aMessage1
message toEndpoint2
.Endpoint2
replies toEndpoint1
with aMessage2
instance.
Transport configuration
var endpointConfiguration = new EndpointConfiguration("Samples.ASBS.SendReply.Endpoint1");
endpointConfiguration.EnableInstallers();
var connectionString = Environment.GetEnvironmentVariable("AzureServiceBus_ConnectionString");
if (string.IsNullOrWhiteSpace(connectionString))
{
throw new Exception("Could not read the 'AzureServiceBus_ConnectionString' environment variable. Check the sample prerequisites.");
}
var transport = new AzureServiceBusTransport(connectionString);
endpointConfiguration.UseTransport(transport);
endpointConfiguration.UseSerialization<SystemJsonSerializer>();
Viewing messages in-flight
The following queues for the two endpoints can be seen in the Azure Portal or a third-party tool:
samples.
asbs. sendreply. endpoint1 samples.
asbs. sendreply. endpoint2 error