Shuttle.Esb
13.2.1
Prefix Reserved
See the version list below for details.
dotnet add package Shuttle.Esb --version 13.2.1
NuGet\Install-Package Shuttle.Esb -Version 13.2.1
<PackageReference Include="Shuttle.Esb" Version="13.2.1" />
<PackageVersion Include="Shuttle.Esb" Version="13.2.1" />
<PackageReference Include="Shuttle.Esb" />
paket add Shuttle.Esb --version 13.2.1
#r "nuget: Shuttle.Esb, 13.2.1"
#addin nuget:?package=Shuttle.Esb&version=13.2.1
#tool nuget:?package=Shuttle.Esb&version=13.2.1
Documentation
Please visit out official documentation for more information.
Getting Started
Start a new Console Application project and select a Shuttle.Esb queue implementation from the supported queues:
PM> Install-Package Shuttle.Esb.AzureStorageQueues
We'll also make use of the .NET generic host:
PM> Install-Package Microsoft.Extensions.Hosting
Next we'll implement our endpoint in order to start listening on our queue:
internal class Program
{
private static void Main()
{
Host.CreateDefaultBuilder()
.ConfigureServices(services =>
{
services.AddServiceBus(builder =>
{
builder.Options.Inbox.WorkQueueUri = "azuresq://azure/work";
});
services.AddAzureStorageQueues(builder =>
{
builder.AddOptions("azure", new AzureStorageQueueOptions
{
ConnectionString = "UseDevelopmentStorage=true;"
});
});
})
.Build()
.Run();
}
}
Even though the options may be set directly as above, typically one would make use of a configuration provider:
internal class Program
{
private static void Main()
{
Host.CreateDefaultBuilder()
.ConfigureServices(services =>
{
var configuration =
new ConfigurationBuilder()
.AddJsonFile("appsettings.json")
.Build();
services.AddSingleton<IConfiguration>(configuration);
services.AddServiceBus(builder =>
{
configuration
.GetSection(ServiceBusOptions.SectionName)
.Bind(builder.Options);
});
services.AddAzureStorageQueues(builder =>
{
builder.AddOptions("azure", new AzureStorageQueueOptions
{
ConnectionString = configuration
.GetConnectionString("azure")
});
});
})
.Build()
.Run();
}
}
The appsettings.json
file would be as follows:
{
"ConnectionStrings": {
"azure": "UseDevelopmentStorage=true;"
},
"Shuttle": {
"ServiceBus": {
"Inbox": {
"WorkQueueUri": "azuresq://azure/work",
}
}
}
}
Send a command message for processing
bus.Send(new RegisterMember
{
UserName = "user-name",
EMailAddress = "user@domain.com"
});
Publish an event message when something interesting happens
Before publishing an event one would need to register an ISubscrtiptionService
implementation such as Shuttle.Esb.Sql.Subscription.
bus.Publish(new MemberRegistered
{
UserName = "user-name"
});
Subscribe to those interesting events
services.AddServiceBus(builder =>
{
builder.AddSubscription<MemberRegistered>();
});
Handle any messages
public class RegisterMemberHandler : IMessageHandler<RegisterMember>
{
public RegisterMemberHandler(IDependency dependency)
{
}
public void ProcessMessage(IHandlerContext<RegisterMember> context)
{
// perform member registration
context.Publish(new MemberRegistered
{
UserName = context.Message.UserName
});
}
}
public class MemberRegisteredHandler : IMessageHandler<MemberRegistered>
{
public void ProcessMessage(IHandlerContext<MemberRegistered> context)
{
// processing
}
}
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net5.0 was computed. net5.0-windows was computed. net6.0 was computed. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. net9.0 was computed. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
.NET Core | netcoreapp2.0 was computed. netcoreapp2.1 was computed. netcoreapp2.2 was computed. netcoreapp3.0 was computed. netcoreapp3.1 was computed. |
.NET Standard | netstandard2.0 is compatible. netstandard2.1 is compatible. |
.NET Framework | net461 was computed. net462 was computed. net463 was computed. net47 was computed. net471 was computed. net472 was computed. net48 was computed. net481 was computed. |
MonoAndroid | monoandroid was computed. |
MonoMac | monomac was computed. |
MonoTouch | monotouch was computed. |
Tizen | tizen40 was computed. tizen60 was computed. |
Xamarin.iOS | xamarinios was computed. |
Xamarin.Mac | xamarinmac was computed. |
Xamarin.TVOS | xamarintvos was computed. |
Xamarin.WatchOS | xamarinwatchos was computed. |
-
- Microsoft.Extensions.DependencyInjection (>= 7.0.0)
- Microsoft.Extensions.Hosting (>= 7.0.0)
- Shuttle.Core.Compression (>= 11.0.1)
- Shuttle.Core.Encryption (>= 11.0.1)
- Shuttle.Core.Pipelines (>= 12.1.1)
- Shuttle.Core.PipelineTransaction (>= 11.0.1)
- Shuttle.Core.Reflection (>= 12.0.1)
- Shuttle.Core.Serialization (>= 10.0.7)
- Shuttle.Core.Specification (>= 11.0.0)
- Shuttle.Core.Streams (>= 10.1.1)
- Shuttle.Core.System (>= 11.0.3)
- Shuttle.Core.Threading (>= 12.0.1)
- Shuttle.Core.Transactions (>= 11.0.1)
NuGet packages (31)
Showing the top 5 NuGet packages that depend on Shuttle.Esb:
Package | Downloads |
---|---|
Shuttle.Esb.RabbitMQ
RabbitMQ implementation for use with Shuttle.Esb. |
|
Shuttle.Esb.Tests
Test fixtures to facilitate testing of components, such as queues, that relate to Shuttle.Esb. |
|
Shuttle.Esb.Process
Shuttle.Esb process management using Shuttle.Recall event sourcing. |
|
Shuttle.Esb.FileMQ
File-based queue implementation for use with Shuttle.Esb. |
|
Shuttle.Esb.Msmq
MSMQ implementation for use with Shuttle.Esb. |
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last Updated |
---|---|---|
20.0.0 | 1,412 | 2/2/2025 |
15.0.0 | 1,492 | 8/5/2024 |
14.0.1 | 1,878 | 5/3/2024 |
14.0.0 | 732 | 4/30/2024 |
13.2.1 | 12,418 | 12/1/2022 |
13.2.0 | 9,510 | 9/16/2022 |
13.1.0 | 8,090 | 9/11/2022 |
13.0.0 | 8,011 | 9/4/2022 |
12.1.1 | 1,594 | 5/18/2022 |
12.1.0 | 1,397 | 5/18/2022 |
12.0.1 | 9,380 | 4/9/2022 |
12.0.0 | 8,522 | 3/21/2022 |
11.2.0 | 8,323 | 2/15/2021 |
11.1.1 | 1,609 | 2/9/2021 |
11.1.0 | 1,781 | 1/30/2021 |
11.0.3 | 12,823 | 1/17/2021 |
11.0.2 | 2,289 | 11/27/2020 |
11.0.1 | 21,864 | 7/31/2019 |
11.0.0 | 13,076 | 6/20/2019 |
10.1.8 | 2,993 | 12/26/2018 |
10.1.7 | 1,956 | 12/9/2018 |
10.1.6 | 41,111 | 10/15/2018 |
10.1.4 | 1,937 | 10/13/2018 |
10.1.2 | 4,133 | 10/6/2018 |
10.1.1 | 4,885 | 9/19/2018 |
10.1.0 | 2,431 | 9/17/2018 |
10.0.10 | 3,984 | 7/10/2018 |
10.0.9 | 2,420 | 7/8/2018 |
10.0.7 | 2,335 | 4/22/2018 |
10.0.6 | 3,109 | 4/12/2018 |
10.0.5 | 3,116 | 4/8/2018 |
10.0.3 | 8,770 | 2/13/2018 |
9.1.4 | 3,469 | 12/29/2017 |
9.1.3 | 2,280 | 10/22/2017 |
9.0.3 | 2,341 | 8/26/2017 |
9.0.2 | 3,909 | 8/6/2017 |
8.0.14 | 2,745 | 3/23/2018 |
8.0.13 | 5,083 | 12/29/2017 |
8.0.12 | 2,707 | 7/20/2017 |
8.0.11 | 2,307 | 7/17/2017 |
8.0.9 | 2,321 | 7/14/2017 |
8.0.8 | 2,922 | 7/6/2017 |
8.0.7 | 6,120 | 5/15/2017 |
8.0.5 | 2,563 | 5/7/2017 |
8.0.4 | 2,295 | 5/6/2017 |
8.0.3 | 2,547 | 5/6/2017 |
8.0.1 | 2,489 | 4/23/2017 |
8.0.0 | 8,276 | 3/24/2017 |
7.0.4 | 3,565 | 10/26/2016 |
7.0.3 | 3,072 | 10/4/2016 |
7.0.1 | 3,173 | 9/19/2016 |
7.0.0 | 2,502 | 9/4/2016 |
6.2.1 | 2,800 | 7/26/2016 |
6.2.0 | 3,107 | 7/23/2016 |
6.1.3 | 2,671 | 6/6/2016 |
6.1.2 | 2,398 | 6/4/2016 |
6.1.1 | 6,744 | 6/4/2016 |
6.1.0 | 2,997 | 6/4/2016 |
6.0.0 | 7,872 | 4/24/2016 |
5.1.9 | 5,555 | 4/3/2016 |
5.1.6 | 8,027 | 3/21/2016 |