Skip to content

Commit 50c90f0

Browse files
ngallegosngallegos
authored
Merge branch 'master' into helenktsai-patch-1
2 parents a8c5deb + 4a0da54 commit 50c90f0

File tree

109 files changed

+1667
-2001
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

109 files changed

+1667
-2001
lines changed

‎get-started/index.md‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
11
---
2-
title: Get Started
2+
title: Get started with NServiceBus and the Particular Service Platform
33
summary: Get started with NServiceBus and the Particular Service Platform with this list of introductory resources.
4-
reviewed: 2024-01-31
4+
reviewed: 2025-10-29
55
suppressRelated: true
66
---
77

88
NServiceBus makes it quick and easy to send, process, and publish messages across a wide variety of on-premises and cloud-based queuing technologies. All the low-level serialization, threading, and transaction management is handled out-of-the box. Monitoring and debugging are easy to set up thanks to ServicePulse and ServiceInsight.
99

1010
### Start the journey with NServiceBus using these handy resources:
1111

12+
* **[Quickstart tutorial](/tutorials/quickstart/)** - A hands-on tutorial that takes you through an NServiceBus solution covering all the elements of one-way messaging, publish-subscribe, and automatic recovery from exceptions.
1213
* **[NServiceBus technical introduction](/nservicebus/)** - A more technical introduction to NServiceBus as well as the Service Platform.
13-
* **[Quickstart tutorial](/tutorials/quickstart/)** - Get a tour through an NServiceBus solution covering all the elements of one-way messaging, publish-subscribe, and automatic recovery from exceptions.
1414
* **[(Video) - Live coding your first NServiceBus system](https://particular.net/webinars/live-coding-your-first-nservicebus-system)** - For those who prefer to sit back and watch an experienced developer build a messaging system with NServiceBus.
1515
* **[NServiceBus overview](https://particular.net/nservicebus)** - The most important benefits of NServiceBus at a glance.
1616
* **[The Particular Service Platform](/platform/)** - The wider benefits of the platform and where NServiceBus fits in.

‎monitoring/metrics/performance-counters_counters_perfcounters_[2,).partial.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
All counters are defined in the NuGet package dependency [NServiceBus.Metrics](https://www.nuget.org/packages/NServiceBus.Metrics/). The dependency is automatically pulled in.
44

5-
For more information about the metrics, defined consult the [Metrics](.) documentation page.
5+
For more information about the metrics defined, consult the [Metrics](.) documentation page.
66

77

88
### Configuration

‎nservicebus/throughput-tool/azure-service-bus.png‎

-57.2 KB
Loading

‎nservicebus/throughput-tool/index.md‎

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -90,39 +90,41 @@ Completing these steps stores credentials that can be used by the tool.
9090

9191
#### Running the tool
9292

93-
To run the tool, the resource ID for the Azure Service Bus namespace is needed.
93+
To run the tool, the resource ID and the region for the Azure Service Bus namespace is needed.
9494

95-
In the Azure Portal, go to the Azure Service Bus namespace, click **Properties** in the side navigation (as shown in the screenshot below) and then copy the `Id` value, which will be needed to run the tool. The `Id` value should have a format similar to `/subscriptions/{Guid}/resourceGroups/{rsrcGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}`.
95+
In the Azure Portal, go to the Azure Service Bus namespace, click **Properties** in the side navigation (as shown in the screenshot below) and then copy the `Id` and `Location` values, which will be needed to run the tool. The `Id` value should have a format similar to `/subscriptions/{Guid}/resourceGroups/{rsrcGroupName}/providers/Microsoft.ServiceBus/namespaces/{namespaceName}`.
9696

97-
This screenshot shows how to copy the Service Bus Namespace's `Id` value:
97+
This screenshot shows how to copy the Service Bus Namespace's `Id` value - the `Location` value can be copied in the same way:
9898

9999
![How to collect the Service Bus Namespace Id](azure-service-bus.png)
100100

101-
Execute the tool with the resource ID of the Azure Service Bus namespace.
101+
Execute the tool with the resource ID and region of the Azure Service Bus namespace.
102102

103103
If the tool was [installed as a .NET tool](/nservicebus/throughput-tool/#installation-net-tool-recommended):
104104

105105
```shell
106-
throughput-counter azureservicebus [options] --resourceId /subscriptions/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx/resourceGroups/my-resource-group/providers/Microsoft.ServiceBus/namespaces/my-asb-namespace
106+
throughput-counter azureservicebus [options] --resourceId /subscriptions/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx/resourceGroups/my-resource-group/providers/Microsoft.ServiceBus/namespaces/my-asb-namespace --region xxxxxxxxx
107107
```
108108

109109
Or, if using the [self-contained executable](/nservicebus/throughput-tool/#installation-self-contained-executable):
110110

111111
```shell
112-
Particular.EndpointThroughputCounter.exe azureservicebus [options] --resourceId /subscriptions/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx/resourceGroups/my-resource-group/providers/Microsoft.ServiceBus/namespaces/my-asb-namespace
112+
Particular.EndpointThroughputCounter.exe azureservicebus [options] --resourceId /subscriptions/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx/resourceGroups/my-resource-group/providers/Microsoft.ServiceBus/namespaces/my-asb-namespace --region xxxxxxxxx
113113
```
114114

115115
#### Options
116116

117117
| Option | Description |
118118
|-|-|
119119
| <nobr>`--resourceId`</nobr> | **Required** – The resource ID of the Azure Service Bus namespace, which can be found in the Azure Portal as described above. |
120+
| <nobr>`--region`</nobr> | **Required** – The Azure region where the Service Bus namespace is located, which can be found in the Azure Portal as described above. Note that the region value should be the [Programmatic name](https://learn.microsoft.com/en-us/azure/reliability/regions-list) for the region. |
120121
| <nobr>`--serviceBusDomain`</nobr> | The Service Bus domain. Defaults to `servicebus.windows.net`. Only necessary for Azure customers using a [non-public/government cloud](https://learn.microsoft.com/en-us/rest/api/servicebus/). |
122+
| <nobr>`--metricsDomain`</nobr> | The monitoring metrics domain. Defaults to `metrics.monitor.azure.com`. Only necessary for Azure customers using a [non-public/government cloud](https://learn.microsoft.com/en-us/dotnet/api/overview/azure/monitor.query-readme?view=azure-dotnet#configure-client-for-azure-sovereign-cloud). |
121123
include: throughput-tool-global-options
122124

123125
#### What the tool does
124126

125-
First, the tool uses a `ServiceBusAdministrationClient` to [query the queue names](https://learn.microsoft.com/en-us/dotnet/api/azure.messaging.servicebus.administration.servicebusadministrationclient.getqueuesasync?view=azure-dotnet) from the namespace. Next, a `MetricsQueryClient` is used to [query for `CompleteMessage` metrics](https://learn.microsoft.com/en-us/dotnet/api/azure.monitor.query.metricsqueryclient.queryresourceasync?view=azure-dotnet) for the past 30 days from each queue.
127+
First, the tool uses a `ServiceBusAdministrationClient` to [query the queue names](https://learn.microsoft.com/en-us/dotnet/api/azure.messaging.servicebus.administration.servicebusadministrationclient.getqueuesasync?view=azure-dotnet) from the namespace. Next, a `MetricsClient` is used to [query for `CompleteMessage` metrics](https://learn.microsoft.com/en-us/dotnet/api/azure.monitor.query.metricsclient.queryresourcesasync?view=azure-dotnet) for the past 30 days from each queue.
126128

127129
Using Azure Service Bus metrics allows the tool to capture the last 30 days worth of data at once. Although the tool collects 30 days worth of data, only the highest daily throughput is included in the report.
128130

‎nservicebus/upgrades/9to10/index.md‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public class CustomPersistence : PersistenceDefinition
9696
Supports<StorageType.Outbox>(s => s.EnableFeatureByDefault<OutboxStorage>());
9797
}
9898
}
99-
````
99+
```
100100

101101
must be changed to `Supports<TStorageType, TFeatureType>()` like this:
102102

@@ -109,4 +109,5 @@ public class CustomPersistence : PersistenceDefinition
109109
Supports<StorageType.Subscriptions, SubscrptionStorage>();
110110
Supports<StorageType.Outbox, OutboxStorage>();
111111
}
112-
}
112+
}
113+
```

‎nservicebus/upgrades/all-versions.include.md‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1126,11 +1126,13 @@
11261126

11271127
| Version | Released | Supported until | Notes |
11281128
|:---------:|:--------------:|:-----------------:|:---------------------------------:|
1129-
| [3.59.x](https://www.nuget.org/packages/Particular.PlatformSample/3.59.0) | 2025-09-18 | - | - |
1129+
| [3.61.x](https://www.nuget.org/packages/Particular.PlatformSample/3.61.0) | 2025-10-29 | - | - |
1130+
| [3.60.x](https://www.nuget.org/packages/Particular.PlatformSample/3.60.0) | 2025-10-29 | 2026-01-29 | Superseded by 3.61.x |
1131+
| [3.59.x](https://www.nuget.org/packages/Particular.PlatformSample/3.59.0) | 2025-09-18 | 2026-01-29 | Superseded by 3.60.x |
11301132
| [3.58.x](https://www.nuget.org/packages/Particular.PlatformSample/3.58.0) | 2025-09-17 | 2025-12-18 | Superseded by 3.59.x |
11311133
| [3.57.x](https://www.nuget.org/packages/Particular.PlatformSample/3.57.0) | 2025-08-21 | 2025-12-17 | Superseded by 3.58.x |
11321134
| [3.56.x](https://www.nuget.org/packages/Particular.PlatformSample/3.56.1) | 2025-07-31 | 2025-11-21 | Superseded by 3.57.x |
1133-
| [3.54.x](https://www.nuget.org/packages/Particular.PlatformSample/3.54.0) | 2025-07-15 | 2025-10-31 | Superseded by 3.56.x |
1135+
| [~~3.54.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.54.0) | ~~2025-07-15~~ | ~~2025-10-31~~ | ~~Superseded by 3.56.x~~ |
11341136
| [~~3.51.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.51.0) | ~~2025-05-23~~ | ~~2025-10-15~~ | ~~Superseded by 3.54.x~~ |
11351137
| [~~3.49.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.49.0) | ~~2025-05-19~~ | ~~2025-08-23~~ | ~~Superseded by 3.51.x~~ |
11361138
| [~~3.47.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.47.0) | ~~2025-05-13~~ | ~~2025-08-19~~ | ~~Superseded by 3.49.x~~ |

‎nservicebus/upgrades/supported-versions-downstreams.include.md‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -571,11 +571,13 @@
571571

572572
| Version | Released | Supported until | Notes |
573573
|:---------:|:--------------:|:-----------------:|:---------------------------------:|
574-
| [3.59.x](https://www.nuget.org/packages/Particular.PlatformSample/3.59.0) | 2025-09-18 | - | - |
574+
| [3.61.x](https://www.nuget.org/packages/Particular.PlatformSample/3.61.0) | 2025-10-29 | - | - |
575+
| [3.60.x](https://www.nuget.org/packages/Particular.PlatformSample/3.60.0) | 2025-10-29 | 2026-01-29 | Superseded by 3.61.x |
576+
| [3.59.x](https://www.nuget.org/packages/Particular.PlatformSample/3.59.0) | 2025-09-18 | 2026-01-29 | Superseded by 3.60.x |
575577
| [3.58.x](https://www.nuget.org/packages/Particular.PlatformSample/3.58.0) | 2025-09-17 | 2025-12-18 | Superseded by 3.59.x |
576578
| [3.57.x](https://www.nuget.org/packages/Particular.PlatformSample/3.57.0) | 2025-08-21 | 2025-12-17 | Superseded by 3.58.x |
577579
| [3.56.x](https://www.nuget.org/packages/Particular.PlatformSample/3.56.1) | 2025-07-31 | 2025-11-21 | Superseded by 3.57.x |
578-
| [3.54.x](https://www.nuget.org/packages/Particular.PlatformSample/3.54.0) | 2025-07-15 | 2025-10-31 | Superseded by 3.56.x |
580+
| [~~3.54.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.54.0) | ~~2025-07-15~~ | ~~2025-10-31~~ | ~~Superseded by 3.56.x~~ |
579581
| [~~3.51.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.51.0) | ~~2025-05-23~~ | ~~2025-10-15~~ | ~~Superseded by 3.54.x~~ |
580582
| [~~3.49.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.49.0) | ~~2025-05-19~~ | ~~2025-08-23~~ | ~~Superseded by 3.51.x~~ |
581583
| [~~3.47.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.47.0) | ~~2025-05-13~~ | ~~2025-08-19~~ | ~~Superseded by 3.49.x~~ |
@@ -589,7 +591,6 @@
589591
| [~~3.33.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.33.0) | ~~2025-03-03~~ | ~~2025-06-17~~ | ~~Superseded by 3.34.x~~ |
590592
| [~~3.32.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.32.0) | ~~2025-02-21~~ | ~~2025-06-03~~ | ~~Superseded by 3.33.x~~ |
591593
| [~~3.26.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.26.0) | ~~2025-02-03~~ | ~~2025-05-21~~ | ~~Superseded by 3.32.x~~ |
592-
| [~~3.25.x~~](https://www.nuget.org/packages/Particular.PlatformSample/3.25.0) | ~~2025-01-27~~ | ~~2025-05-03~~ | ~~Superseded by 3.26.x~~ |
593594

594595
#### [ServiceControl.Contracts](/nuget/ServiceControl.Contracts)
595596

‎nservicebus/upgrades/supported-versions.json‎

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1151,10 +1151,6 @@
11511151
{
11521152
"PackageId": "Particular.PlatformSample",
11531153
"Versions": [
1154-
{
1155-
"Minor": "3.54",
1156-
"SupportLevel": "Mainstream"
1157-
},
11581154
{
11591155
"Minor": "3.56",
11601156
"SupportLevel": "Mainstream"
@@ -1170,6 +1166,14 @@
11701166
{
11711167
"Minor": "3.59",
11721168
"SupportLevel": "Mainstream"
1169+
},
1170+
{
1171+
"Minor": "3.60",
1172+
"SupportLevel": "Mainstream"
1173+
},
1174+
{
1175+
"Minor": "3.61",
1176+
"SupportLevel": "Mainstream"
11731177
}
11741178
]
11751179
},

‎platform/third-party-license-data.include.md‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,9 @@
1010

1111
| Dependency | License | Project Site |
1212
|:-----------|:-------:|:------------:|
13-
| <a href="https://www.nuget.org/packages/AWSSDK.S3" target="_blank">AWSSDK.S3</a> | <a href="https://www.nuget.org/packages/AWSSDK.S3/4.0.8/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
14-
| <a href="https://www.nuget.org/packages/AWSSDK.SQS" target="_blank">AWSSDK.SQS</a> | <a href="https://www.nuget.org/packages/AWSSDK.SQS/4.0.1.13/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
15-
| <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken" target="_blank">AWSSDK.SecurityToken</a> | <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken/4.0.2.11/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
13+
| <a href="https://www.nuget.org/packages/AWSSDK.S3" target="_blank">AWSSDK.S3</a> | <a href="https://www.nuget.org/packages/AWSSDK.S3/4.0.9.1/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
14+
| <a href="https://www.nuget.org/packages/AWSSDK.SQS" target="_blank">AWSSDK.SQS</a> | <a href="https://www.nuget.org/packages/AWSSDK.SQS/4.0.2/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
15+
| <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken" target="_blank">AWSSDK.SecurityToken</a> | <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken/4.0.3/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
1616
| <a href="https://www.nuget.org/packages/AWSSDK.SimpleNotificationService" target="_blank">AWSSDK.SimpleNotificationService</a> | <a href="https://www.nuget.org/packages/AWSSDK.SimpleNotificationService/4.0.2.2/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
1717
| <a href="https://www.nuget.org/packages/BitFaster.Caching" target="_blank">BitFaster.Caching</a> | <a href="https://www.nuget.org/packages/BitFaster.Caching/2.5.4/license" target="_blank">View License</a> | <i>None provided</i> |
1818

@@ -163,7 +163,7 @@
163163

164164
| Dependency | License | Project Site |
165165
|:-----------|:-------:|:------------:|
166-
| <a href="https://www.nuget.org/packages/AWSSDK.DynamoDBv2" target="_blank">AWSSDK.DynamoDBv2</a> | <a href="https://www.nuget.org/packages/AWSSDK.DynamoDBv2/4.0.9.2/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
166+
| <a href="https://www.nuget.org/packages/AWSSDK.DynamoDBv2" target="_blank">AWSSDK.DynamoDBv2</a> | <a href="https://www.nuget.org/packages/AWSSDK.DynamoDBv2/4.0.9.3/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
167167

168168
### NServiceBus.Persistence.ServiceFabric
169169

@@ -257,8 +257,8 @@
257257
| Dependency | License | Project Site |
258258
|:-----------|:-------:|:------------:|
259259
| <a href="https://www.nuget.org/packages/Autofac" target="_blank">Autofac</a> | <a href="https://www.nuget.org/packages/Autofac/8.4.0/license" target="_blank">MIT</a> | <a href="https://autofac.org/" target="_blank">Project Site</a> |
260-
| <a href="https://www.nuget.org/packages/AWSSDK.CloudWatch" target="_blank">AWSSDK.CloudWatch</a> | <a href="https://www.nuget.org/packages/AWSSDK.CloudWatch/4.0.4.8/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
261-
| <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken" target="_blank">AWSSDK.SecurityToken</a> | <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken/4.0.2.11/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
260+
| <a href="https://www.nuget.org/packages/AWSSDK.CloudWatch" target="_blank">AWSSDK.CloudWatch</a> | <a href="https://www.nuget.org/packages/AWSSDK.CloudWatch/4.0.5/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
261+
| <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken" target="_blank">AWSSDK.SecurityToken</a> | <a href="https://www.nuget.org/packages/AWSSDK.SecurityToken/4.0.3/license" target="_blank">Apache-2.0</a> | <a href="https://github.com/aws/aws-sdk-net/" target="_blank">Project Site</a> |
262262
| <a href="https://www.nuget.org/packages/Azure.Identity" target="_blank">Azure.Identity</a> | <a href="https://www.nuget.org/packages/Azure.Identity/1.17.0/license" target="_blank">MIT</a> | <a href="https://github.com/Azure/azure-sdk-for-net/blob/Azure.Identity_1.17.0/sdk/identity/Azure.Identity/README.md" target="_blank">Project Site</a> |
263263
| <a href="https://www.nuget.org/packages/Azure.Monitor.Query.Metrics" target="_blank">Azure.Monitor.Query.Metrics</a> | <a href="https://www.nuget.org/packages/Azure.Monitor.Query.Metrics/1.0.0/license" target="_blank">MIT</a> | <a href="https://github.com/Azure/azure-sdk-for-net/blob/Azure.Monitor.Query.Metrics_1.0.0/sdk/monitor/Azure.Monitor.Query.Metrics/README.md" target="_blank">Project Site</a> |
264264
| <a href="https://www.nuget.org/packages/Azure.ResourceManager.ServiceBus" target="_blank">Azure.ResourceManager.ServiceBus</a> | <a href="https://www.nuget.org/packages/Azure.ResourceManager.ServiceBus/1.1.0/license" target="_blank">MIT</a> | <a href="https://github.com/Azure/azure-sdk-for-net/blob/Azure.ResourceManager.ServiceBus_1.1.0/sdk/servicebus/Azure.ResourceManager.ServiceBus/README.md" target="_blank">Project Site</a> |

‎samples/asyncapi/custom-message-types/Core_10/AsyncAPI.GenericHost/Program.cs‎

Lines changed: 43 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,47 @@
2424
builder.Services.AddHostedService<AsyncAPISchemaWriter>();
2525
#endregion
2626

27-
builder.Services.AddHostedService<Worker>();
27+
var host = builder.Build();
2828

29-
var app = builder.Build();
30-
await app.RunAsync();
29+
await host.StartAsync();
30+
31+
var messageSession = host.Services.GetRequiredService<IMessageSession>();
32+
33+
Console.WriteLine("Press '1' to publish event 1");
34+
Console.WriteLine("Press '2' to publish event 2");
35+
Console.WriteLine("Press 's' to send local message");
36+
Console.WriteLine("Press any other key to exit");
37+
38+
var number = 0;
39+
var continueInputLoop = true;
40+
41+
while (continueInputLoop)
42+
{
43+
var key = Console.ReadKey();
44+
Console.WriteLine();
45+
46+
var now = DateTime.UtcNow.ToString();
47+
switch (key.Key)
48+
{
49+
case ConsoleKey.D1:
50+
await messageSession.Publish(new FirstEventThatIsBeingPublished { SomeValue = now, SomeOtherValue = now });
51+
52+
Console.WriteLine($"Published event 1 with {now}.");
53+
break;
54+
case ConsoleKey.D2:
55+
await messageSession.Publish(new SecondEventThatIsBeingPublished { SomeValue = now, SomeOtherValue = now });
56+
57+
Console.WriteLine($"Published event 2 with {now}.");
58+
break;
59+
case ConsoleKey.S:
60+
await messageSession.SendLocal(new MessageBeingSent { Number = number++ });
61+
62+
Console.WriteLine($"Sent message with {number}.");
63+
break;
64+
default:
65+
continueInputLoop = false;
66+
break;
67+
}
68+
}
69+
70+
await host.StopAsync();

0 commit comments

Comments
 (0)