Upgrade to latest DotPulsar version

smbecker · smbecker · commit ef8792203243 · 2025-11-11T11:38:07.000-05:00
* This requires switching the ProtoBufSchema to use Google.Protobuf library
* Adds Ulid.Protobuf library to provide similar interop with Google.Protobuf
diff --git a/Directory.Packages.props b/Directory.Packages.props
@@ -3,23 +3,25 @@
     <ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
   </PropertyGroup>
   <ItemGroup>
-    <PackageVersion Include="DotPulsar" Version="4.2.0" />
-    <PackageVersion Include="Microsoft.Extensions.Configuration" Version="8.0.0" />
-    <PackageVersion Include="Microsoft.Extensions.DependencyInjection" Version="8.0.0" />
-    <PackageVersion Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="8.0.0" />
-    <PackageVersion Include="Microsoft.NET.Test.Sdk" Version="17.13.0" />
+    <PackageVersion Include="DotPulsar" Version="5.0.0" />
+    <PackageVersion Include="Google.Protobuf" Version="3.33.0" />
+    <PackageVersion Include="Grpc.Tools" Version="2.76.0" />
+    <PackageVersion Include="Microsoft.Extensions.Configuration" Version="9.0.10" />
+    <PackageVersion Include="Microsoft.Extensions.DependencyInjection" Version="9.0.10" />
+    <PackageVersion Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="9.0.10" />
+    <PackageVersion Include="Microsoft.NET.Test.Sdk" Version="18.0.0" />
     <PackageVersion Include="Microsoft.SourceLink.GitHub" Version="8.0.0" PrivateAssets="all" />
     <PackageVersion Include="MinVer" Version="6.0.0" PrivateAssets="all" />
-    <PackageVersion Include="OpenTelemetry.Api" Version="1.9.0" />
-    <PackageVersion Include="Polly" Version="8.5.2" />
-    <PackageVersion Include="protobuf-net" Version="3.2.46" />
-    <PackageVersion Include="System.Text.Json" Version="8.0.5" />
-    <PackageVersion Include="Testcontainers.Pulsar" Version="4.3.0" />
-    <PackageVersion Include="Ulid" Version="1.3.4" />
+    <PackageVersion Include="OpenTelemetry.Api" Version="1.13.1" />
+    <PackageVersion Include="Polly" Version="8.6.4" />
+    <PackageVersion Include="protobuf-net" Version="3.2.56" />
+    <PackageVersion Include="System.Text.Json" Version="9.0.10" />
+    <PackageVersion Include="Testcontainers.Pulsar" Version="4.8.1" />
+    <PackageVersion Include="Ulid" Version="1.4.1" />
     <PackageVersion Include="xunit" Version="2.9.3" />
-    <PackageVersion Include="xunit.runner.visualstudio" Version="3.0.2">
+    <PackageVersion Include="xunit.runner.visualstudio" Version="3.1.5">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageVersion>
   </ItemGroup>
-</Project>
+</Project>
diff --git a/DotPulsar.Extensions.slnx b/DotPulsar.Extensions.slnx
@@ -9,11 +9,13 @@
     <Project Path="src/DotPulsar.Extensions.OpenTelemetry/DotPulsar.Extensions.OpenTelemetry.csproj" />
     <Project Path="src/DotPulsar.Extensions.Resiliency/DotPulsar.Extensions.Resiliency.csproj" />
     <Project Path="src/DotPulsar.Extensions.Schemas/DotPulsar.Extensions.Schemas.csproj" />
+    <Project Path="src/Ulid.Protobuf/Ulid.Protobuf.csproj" />
     <Project Path="src/Ulid.protobuf-net/Ulid.protobuf-net.csproj" />
   </Folder>
   <Folder Name="/test/">
     <Project Path="test/DotPulsar.Extensions.DependencyInjection.Tests/DotPulsar.Extensions.DependencyInjection.Tests.csproj" />
     <Project Path="test/DotPulsar.Extensions.Resiliency.Tests/DotPulsar.Extensions.Resiliency.Tests.csproj" />
+    <Project Path="test/Ulid.Protobuf.Tests/Ulid.Protobuf.Tests.csproj" />
     <Project Path="test/Ulid.protobuf-net.Tests/Ulid.protobuf-net.Tests.csproj" />
   </Folder>
 </Solution>
diff --git a/src/DotPulsar.Extensions.DependencyInjection/DotPulsar.Extensions.DependencyInjection.csproj b/src/DotPulsar.Extensions.DependencyInjection/DotPulsar.Extensions.DependencyInjection.csproj
@@ -4,7 +4,7 @@
 		<RootNamespace>DotPulsar</RootNamespace>
 		<PackageTags>$(PackageTags);Pulsar</PackageTags>
 		<Description>DotPulsar.Extensions.DependencyInjection adds support for using DotPulsar with the Microsoft.Extensions.DependencyInjection APIs.</Description>
-		<TargetFrameworks>net6.0;net7.0;net8.0;net9.0</TargetFrameworks>
+		<TargetFrameworks>net8.0;net9.0</TargetFrameworks>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<Nullable>enable</Nullable>
 		<LangVersion>latest</LangVersion>
diff --git a/src/DotPulsar.Extensions.OpenTelemetry/DotPulsar.Extensions.OpenTelemetry.csproj b/src/DotPulsar.Extensions.OpenTelemetry/DotPulsar.Extensions.OpenTelemetry.csproj
@@ -4,7 +4,7 @@
 		<RootNamespace>DotPulsar</RootNamespace>
 		<PackageTags>$(PackageTags);Pulsar</PackageTags>
 		<Description>DotPulsar.OpenTelemetry integrates DotPulsar with OpenTelemetry APIs.</Description>
-		<TargetFrameworks>net6.0;net7.0;net8.0;net9.0</TargetFrameworks>
+		<TargetFrameworks>netstandard2.0;netstandard2.1;net8.0;net9.0</TargetFrameworks>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<Nullable>enable</Nullable>
 		<LangVersion>latest</LangVersion>
diff --git a/src/DotPulsar.Extensions.OpenTelemetry/PulsarMeterProviderBuilderExtensions.cs b/src/DotPulsar.Extensions.OpenTelemetry/PulsarMeterProviderBuilderExtensions.cs
@@ -6,7 +6,13 @@ namespace OpenTelemetry.Metrics;
 public static class PulsarMeterProviderBuilderExtensions
 {
 	public static MeterProviderBuilder AddPulsarInstrumentation(this MeterProviderBuilder builder) {
+#if NET7_0_OR_GREATER
 		ArgumentNullException.ThrowIfNull(builder);
+#else
+		if (builder is null) {
+			throw new ArgumentNullException(nameof(builder));
+		}
+#endif
 		builder.AddMeter(Constants.ClientName);
 		return builder;
 	}
diff --git a/src/DotPulsar.Extensions.OpenTelemetry/PulsarTracerProviderBuilderExtensions.cs b/src/DotPulsar.Extensions.OpenTelemetry/PulsarTracerProviderBuilderExtensions.cs
@@ -6,7 +6,13 @@ namespace OpenTelemetry.Trace;
 public static class PulsarTracerProviderBuilderExtensions
 {
 	public static TracerProviderBuilder AddPulsarInstrumentation(this TracerProviderBuilder builder) {
+#if NET7_0_OR_GREATER
 		ArgumentNullException.ThrowIfNull(builder);
+#else
+		if (builder is null) {
+			throw new ArgumentNullException(nameof(builder));
+		}
+#endif
 		builder.AddSource(Constants.ClientName);
 		return builder;
 	}
diff --git a/src/DotPulsar.Extensions.Resiliency/DotPulsar.Extensions.Resiliency.csproj b/src/DotPulsar.Extensions.Resiliency/DotPulsar.Extensions.Resiliency.csproj
@@ -4,7 +4,7 @@
 		<RootNamespace>DotPulsar</RootNamespace>
 		<PackageTags>$(PackageTags);Pulsar</PackageTags>
 		<Description>DotPulsar.Extensions.Resiliency adds resiliency extensions working with Pulsar.</Description>
-		<TargetFrameworks>netstandard2.0;netstandard2.1;net6.0;net7.0;net8.0;net9.0</TargetFrameworks>
+		<TargetFrameworks>netstandard2.0;netstandard2.1;net8.0;net9.0</TargetFrameworks>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<Nullable>enable</Nullable>
 		<LangVersion>latest</LangVersion>
diff --git a/src/DotPulsar.Extensions.Resiliency/Extensions/PulsarResilientExtensions.cs b/src/DotPulsar.Extensions.Resiliency/Extensions/PulsarResilientExtensions.cs
@@ -81,7 +81,7 @@ public static IProducer<TMessage> CreateResilient<TMessage>(this IProducerBuilde
 #endif
 
 		if (resiliencePipeline == null || Equals(resiliencePipeline, ResiliencePipeline.Empty)) {
-			return producerBuilder.Create();
+			resiliencePipeline = new ResiliencePipelineBuilder().AddResilientProducerDefaults().Build();
 		}
 		return new ResilientProducer<TMessage>(producerBuilder, resiliencePipeline);
 	}
diff --git a/src/DotPulsar.Extensions.Schemas/DotPulsar.Extensions.Schemas.csproj b/src/DotPulsar.Extensions.Schemas/DotPulsar.Extensions.Schemas.csproj
@@ -4,7 +4,7 @@
 		<RootNamespace>DotPulsar</RootNamespace>
 		<PackageTags>$(PackageTags);Pulsar</PackageTags>
 		<Description>DotPulsar.Extensions.Schemas adds support for using Json and ProtoBuf producers, consumers, and receivers.</Description>
-		<TargetFrameworks>netstandard2.1;net6.0;net7.0;net8.0;net9.0</TargetFrameworks>
+		<TargetFrameworks>netstandard2.1;net8.0;net9.0</TargetFrameworks>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<Nullable>enable</Nullable>
 		<LangVersion>latest</LangVersion>
diff --git a/src/DotPulsar.Extensions.Schemas/Extensions/PulsarSchemaExtensions.cs b/src/DotPulsar.Extensions.Schemas/Extensions/PulsarSchemaExtensions.cs
@@ -1,22 +1,47 @@
 using System.Text.Json;
 using DotPulsar.Abstractions;
 using DotPulsar.Schemas;
+using Google.Protobuf;
 
 namespace DotPulsar.Extensions;
 
 public static class PulsarSchemaExtensions
 {
-	public static IProducerBuilder<TMessage> NewProtoBufProducer<TMessage>(this IPulsarClient client) {
+#if NET8_0_OR_GREATER
+	public static IProducerBuilder<TMessage> NewProtoBufProducer<TMessage>(this IPulsarClient client)
+		where TMessage : IMessageWithParser<TMessage> {
 		return client.NewProducer(ProtoBufSchema.Get<TMessage>());
 	}
+#endif
 
-	public static IConsumerBuilder<TMessage> NewProtoBufConsumer<TMessage>(this IPulsarClient client) {
+	public static IProducerBuilder<TMessage> NewProtoBufProducer<TMessage>(this IPulsarClient client, MessageParser<TMessage> parser)
+		where TMessage : Google.Protobuf.IMessage<TMessage> {
+		return client.NewProducer(new ProtoBufSchema<TMessage>(parser));
+	}
+
+#if NET8_0_OR_GREATER
+	public static IConsumerBuilder<TMessage> NewProtoBufConsumer<TMessage>(this IPulsarClient client)
+		where TMessage : IMessageWithParser<TMessage> {
 		return client.NewConsumer(ProtoBufSchema.Get<TMessage>());
 	}
+#endif
+
+	public static IConsumerBuilder<TMessage> NewProtoBufConsumer<TMessage>(this IPulsarClient client, MessageParser<TMessage> parser)
+		where TMessage : Google.Protobuf.IMessage<TMessage> {
+		return client.NewConsumer(new ProtoBufSchema<TMessage>(parser));
+	}
 
-	public static IReaderBuilder<TMessage> NewProtoBufReader<TMessage>(this IPulsarClient client) {
+#if NET8_0_OR_GREATER
+	public static IReaderBuilder<TMessage> NewProtoBufReader<TMessage>(this IPulsarClient client)
+		where TMessage : IMessageWithParser<TMessage> {
 		return client.NewReader(ProtoBufSchema.Get<TMessage>());
 	}
+#endif
+
+	public static IReaderBuilder<TMessage> NewProtoBufReader<TMessage>(this IPulsarClient client, MessageParser<TMessage> parser)
+		where TMessage : Google.Protobuf.IMessage<TMessage> {
+		return client.NewReader(new ProtoBufSchema<TMessage>(parser));
+	}
 
 	public static IProducerBuilder<TMessage> NewJsonProducer<TMessage>(this IPulsarClient client, JsonSerializerOptions? serializerOptions = null) {
 		return client.NewProducer(JsonSchema.Get<TMessage>(serializerOptions));
diff --git a/src/DotPulsar.Extensions.Schemas/Schemas/IMessageWithParser.cs b/src/DotPulsar.Extensions.Schemas/Schemas/IMessageWithParser.cs
@@ -0,0 +1,26 @@
+// /*
+//  * Licensed under the Apache License, Version 2.0 (the "License")
+//  * you may not use this file except in compliance with the License.
+//  * You may obtain a copy of the License at
+//  *
+//  *   http://www.apache.org/licenses/LICENSE-2.0
+//  *
+//  * Unless required by applicable law or agreed to in writing, software
+//  * distributed under the License is distributed on an "AS IS" BASIS,
+//  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//  * See the License for the specific language governing permissions and
+//  * limitations under the License.
+//  */
+
+#if NET8_0_OR_GREATER
+// ReSharper disable once CheckNamespace
+namespace Google.Protobuf;
+
+public interface IMessageWithParser<T> : IMessage<T>
+	where T : IMessage<T>
+{
+	static abstract MessageParser<T> Parser {
+		get;
+	}
+}
+#endif
diff --git a/src/DotPulsar.Extensions.Schemas/Schemas/ProtoBufSchema.cs b/src/DotPulsar.Extensions.Schemas/Schemas/ProtoBufSchema.cs
@@ -1,45 +1,57 @@
 using System.Buffers;
 using DotPulsar.Abstractions;
+using Google.Protobuf;
 
 namespace DotPulsar.Schemas;
 
+#if NET8_0_OR_GREATER
 public static class ProtoBufSchema
 {
-	public static ISchema<TMessage> Get<TMessage>() {
-		return ProtoBufSchema<TMessage>.Instance;
+	public static ISchema<TMessage> Get<TMessage>()
+		where TMessage : IMessageWithParser<TMessage> {
+		return ProtoBufSchemaCache<TMessage>.Instance;
+	}
+
+	private static class ProtoBufSchemaCache<TMessage>
+		where TMessage : IMessageWithParser<TMessage>
+	{
+		internal static ProtoBufSchema<TMessage> Instance {
+			get;
+		} = new(TMessage.Parser);
 	}
 }
+#endif
 
 /// <summary>
 /// A schema that uses ProtoBuf to serialize and deserialize messages.
 /// </summary>
 /// <typeparam name="TMessage"></typeparam>
 /// <remarks>This still relies on the native Bytes schema rather than leveraging the official Pulsar schema registry.</remarks>
-public sealed class ProtoBufSchema<TMessage> : TypedSchema<TMessage>
+public sealed class ProtoBufSchema<TMessage> : TypedSchema<TMessage> where TMessage : Google.Protobuf.IMessage<TMessage>
 {
-	public ProtoBufSchema() {
+	private readonly MessageParser<TMessage> parser;
+
+	public ProtoBufSchema(MessageParser<TMessage> parser) {
+		this.parser = parser ?? throw new ArgumentNullException(nameof(parser));
 	}
 
-	public ProtoBufSchema(ISchema<ReadOnlySequence<byte>> byteSchema)
+	public ProtoBufSchema(MessageParser<TMessage> parser, ISchema<ReadOnlySequence<byte>> byteSchema)
 		: base(byteSchema) {
+		this.parser = parser ?? throw new ArgumentNullException(nameof(parser));
 	}
 
-	internal static ProtoBufSchema<TMessage> Instance {
-		get;
-	} = new();
-
 	protected override TMessage DecodeBytes(ReadOnlySequence<byte> bytes) {
-		return ProtoBuf.Serializer.Deserialize<TMessage>(bytes);
+		return parser.ParseFrom(bytes);
 	}
 
 	protected override ReadOnlySequence<byte> EncodeBytes(TMessage message) {
-		using var measure = ProtoBuf.Serializer.Measure(message);
-		if (measure.Length <= 0) {
+		var length = message.CalculateSize();
+		if (length <= 0) {
 			return ReadOnlySequence<byte>.Empty;
 		}
 
-		var writer = new ArrayBufferWriter<byte>((int)measure.Length);
-		measure.Serialize(writer);
+		var writer = new ArrayBufferWriter<byte>(length);
+		message.WriteTo(writer);
 		return new ReadOnlySequence<byte>(writer.WrittenMemory);
 	}
 }
diff --git a/src/Ulid.Protobuf/README.md b/src/Ulid.Protobuf/README.md
@@ -0,0 +1,16 @@
+﻿# Ulid Protobuf Extensions
+
+_[![Build status](https://github.com/smbecker/dotpulsar-extensions/actions/workflows/ci.yaml/badge.svg?branch=main)](https://github.com/smbecker/dotpulsar-extensions/actions/workflows/ci.yaml)_
+_[![CodeQL analysis](https://github.com/smbecker/dotpulsar-extensions/actions/workflows/codeql.yaml/badge.svg?branch=main)](https://github.com/smbecker/dotpulsar-extensions/actions/workflows/codeql.yaml)_
+
+The [Ulid](https://github.com/Cysharp/Ulid) type is not supported by default in [Google.Protobuf](https://github.com/protocolbuffers/protobuf). This package provides the necessary extensions to support `Ulid` as a serializable type.
+
+## Installation
+
+```sh
+dotnet add package Ulid.Protobuf
+```
+
+## License
+
+This project is licensed under [Apache License, Version 2.0](https://apache.org/licenses/LICENSE-2.0).
diff --git a/src/Ulid.Protobuf/Ulid.Protobuf.csproj b/src/Ulid.Protobuf/Ulid.Protobuf.csproj
@@ -0,0 +1,27 @@
+<Project Sdk="Microsoft.NET.Sdk">
+	<PropertyGroup>
+		<RootNamespace>Google.Protobuf.WellKnownTypes</RootNamespace>
+		<PackageTags>$(PackageTags);Ulid;protobuf</PackageTags>
+		<Description>Adds support for Ulid fields within Google.ProtoBuf serializable types.</Description>
+		<TargetFrameworks>netstandard2.0;netstandard2.1;net8.0;net9.0</TargetFrameworks>
+		<LangVersion>latest</LangVersion>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+		<LangVersion>latest</LangVersion>
+		<IncludeSymbols>true</IncludeSymbols>
+		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
+		<PackageReadmeFile>README.md</PackageReadmeFile>
+	</PropertyGroup>
+	<ItemGroup>
+		<None Include="ulid/ulid.proto">
+			<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+			<Pack>True</Pack>
+			<PackagePath>contentFiles/any/any/ulid</PackagePath>
+		</None>
+		<None Include="README.md" Pack="true" PackagePath="" />
+	</ItemGroup>
+	<ItemGroup>
+		<PackageReference Include="Google.Protobuf"/>
+		<PackageReference Include="Ulid"/>
+	</ItemGroup>
+</Project>
diff --git a/src/Ulid.Protobuf/Ulid.cs b/src/Ulid.Protobuf/Ulid.cs
@@ -0,0 +1,50 @@
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
+
+namespace Google.Protobuf.WellKnownTypes;
+
+partial class Ulid : ICustomDiagnosticMessage
+{
+	public Ulid(System.Ulid value) {
+		_surrogate = new UlidSurrogate(value);
+	}
+
+	public System.Ulid ToUlid() {
+		return _surrogate.ToUlid();
+	}
+
+	public Guid ToGuid() {
+		return _surrogate.ToUlid().ToGuid();
+	}
+
+	string ICustomDiagnosticMessage.ToDiagnosticString() => $"\"{ToUlid().ToString()}\"";
+
+	public static implicit operator System.Ulid(Ulid? surrogate) {
+		if (surrogate == null) {
+			return System.Ulid.Empty;
+		}
+		return surrogate.ToUlid();
+	}
+
+	public static implicit operator Ulid(System.Ulid source) {
+		return new Ulid(source);
+	}
+
+	[StructLayout(LayoutKind.Explicit, Size = 16)]
+	private struct UlidSurrogate
+	{
+		[FieldOffset(0)]
+		internal ulong Upper;
+
+		[FieldOffset(8)]
+		internal ulong Lower;
+
+		public UlidSurrogate(System.Ulid value) {
+			this = Unsafe.As<System.Ulid, UlidSurrogate>(ref value);
+		}
+
+		public System.Ulid ToUlid() {
+			return Unsafe.As<UlidSurrogate, System.Ulid>(ref this);
+		}
+	}
+}
diff --git a/src/Ulid.Protobuf/Ulid.pb.cs b/src/Ulid.Protobuf/Ulid.pb.cs
diff --git a/src/Ulid.Protobuf/ulid/ulid.proto b/src/Ulid.Protobuf/ulid/ulid.proto
diff --git a/src/Ulid.protobuf-net/Ulid.protobuf-net.csproj b/src/Ulid.protobuf-net/Ulid.protobuf-net.csproj
diff --git a/src/Ulid.protobuf-net/ulid/ulid.proto b/src/Ulid.protobuf-net/ulid/ulid.proto
diff --git a/test/Ulid.Protobuf.Tests/Ulid.Protobuf.Tests.csproj b/test/Ulid.Protobuf.Tests/Ulid.Protobuf.Tests.csproj
diff --git a/test/Ulid.Protobuf.Tests/UlidTests.cs b/test/Ulid.Protobuf.Tests/UlidTests.cs
diff --git a/test/Ulid.Protobuf.Tests/consumer.proto b/test/Ulid.Protobuf.Tests/consumer.proto

Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,13 @@ namespace OpenTelemetry.Metrics;`
`6`	`6`	`public static class PulsarMeterProviderBuilderExtensions`
`7`	`7`	`{`
`8`	`8`	`public static MeterProviderBuilder AddPulsarInstrumentation(this MeterProviderBuilder builder) {`
	`9`	`+#if NET7_0_OR_GREATER`
`9`	`10`	`ArgumentNullException.ThrowIfNull(builder);`
	`11`	`+#else`
	`12`	`+ if (builder is null) {`
	`13`	`+ throw new ArgumentNullException(nameof(builder));`
	`14`	`+ }`
	`15`	`+#endif`
`10`	`16`	`builder.AddMeter(Constants.ClientName);`
`11`	`17`	`return builder;`
`12`	`18`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,13 @@ namespace OpenTelemetry.Trace;`
`6`	`6`	`public static class PulsarTracerProviderBuilderExtensions`
`7`	`7`	`{`
`8`	`8`	`public static TracerProviderBuilder AddPulsarInstrumentation(this TracerProviderBuilder builder) {`
	`9`	`+#if NET7_0_OR_GREATER`
`9`	`10`	`ArgumentNullException.ThrowIfNull(builder);`
	`11`	`+#else`
	`12`	`+ if (builder is null) {`
	`13`	`+ throw new ArgumentNullException(nameof(builder));`
	`14`	`+ }`
	`15`	`+#endif`
`10`	`16`	`builder.AddSource(Constants.ClientName);`
`11`	`17`	`return builder;`
`12`	`18`	`}`
Original file line number	Diff line number	Diff line change
`@@ -81,7 +81,7 @@ public static IProducer<TMessage> CreateResilient<TMessage>(this IProducerBuilde`
`81`	`81`	`#endif`
`82`	`82`
`83`	`83`	`if (resiliencePipeline == null \|\| Equals(resiliencePipeline, ResiliencePipeline.Empty)) {`
`84`		`- return producerBuilder.Create();`
	`84`	`+ resiliencePipeline = new ResiliencePipelineBuilder().AddResilientProducerDefaults().Build();`
`85`	`85`	`}`
`86`	`86`	`return new ResilientProducer<TMessage>(producerBuilder, resiliencePipeline);`
`87`	`87`	`}`