Prerequisites
The uses a database nservicebus
. Ensure it exists before running the sample.
Running the sample
- Start both the Sender and Receiver projects.
- Press c to send a command, or e to publish an event, from Sender to the Receiver.
- The Receiver handles the message.
Code walk-through
Configuring the PostgreSQL transport
var connectionString = "User ID=user;Password=admin;Host=localhost;Port=54320;Database=nservicebus;Pooling=true;Connection Lifetime=0;Include Error Detail=true";
var routing = endpointConfiguration.UseTransport(new PostgreSqlTransport(connectionString)
{
TransportTransactionMode = TransportTransactionMode.SendsAtomicWithReceive
});
routing.RouteToEndpoint(typeof(MyCommand), "PostgreSql.SimpleReceiver");