Skip to content

Commit 8408fcc

Browse files
committed
Add note about enclosing queuename
1 parent a9f18ec commit 8408fcc

File tree

3 files changed

+12
-1
lines changed

3 files changed

+12
-1
lines changed

Snippets/PostgreSqlTransport/PostgreSqlTransport_8/MultiSchema.cs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,12 @@ async Task OtherEndpointConnectionParamsPull(EndpointConfiguration endpointConfi
3737
endpointConfiguration.SendFailedMessagesTo("myerror");
3838

3939
#endregion
40+
41+
#region postgresql-multischema-config-for-queue-heartbeats
42+
43+
endpointConfiguration.SendHeartbeatTo("\"Particular.ServiceControl\"");
44+
45+
#endregion
4046
}
4147

4248
void ConfigureCustomSchemaForEndpoint(EndpointConfiguration endpointConfiguration)

Snippets/PostgreSqlTransport/PostgreSqlTransport_8/PostgreSqlTransport_8.csproj

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
<ItemGroup>
88
<PackageReference Include="Azure.Identity" Version="1.12.0" />
99
<PackageReference Include="NServiceBus.Transport.PostgreSql" Version="8.*" />
10+
<PackageReference Include="NServiceBus.Heartbeat" Version="5.*" />
1011
<PackageReference Include="NUnit" Version="4.*" />
1112
<PackageReference Include="NUnit.Analyzers" Version="4.3.0" />
1213
<PackageReference Include="NUnit3TestAdapter" Version="4.*" />

transports/postgresql/addressing.md

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,11 +42,15 @@ snippet: postgresql-multischema-config-for-queue-send
4242

4343
snippet: postgresql-multischema-config-for-queue-error
4444

45+
> [!NOTE]
46+
> If the queue name contains a "." and the first part is not a schema name, enclose the queue name in quotes.
47+
48+
snippet: postgresql-multischema-config-for-queue-heartbeats
49+
4550
The entire algorithm for calculating the schema is the following:
4651

4752
* If the schema is configured for a given queue via `UseSchemaForQueue`, the configured value is used.
4853
* If [logical routing](/nservicebus/messaging/routing.md#command-routing) is used and schema is configured for a given endpoint via `UseSchemaForEndpoint`, the configured schema is used.
4954
* If destination address contains a schema, the schema from address is used.
5055
* If default schema is configured via `DefaultSchema`, the configured value is used.
5156
* Otherwise, `public` is used as a default schema.
52-

0 commit comments

Comments
 (0)