Skip to content

Commit 11590db

Browse files
committed
Fixed forwarding of StatusChanged event
1 parent ea8193b commit 11590db

File tree

1 file changed

+1
-16
lines changed

1 file changed

+1
-16
lines changed

RabbitMQ.Stream.Client/Reliable/DeduplicatingProducer.cs

Lines changed: 1 addition & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -39,22 +39,7 @@ public static async Task<DeduplicatingProducer> Create(DeduplicatingProducerConf
3939
var x = new DeduplicatingProducer()
4040
{
4141
_producer = await Producer
42-
.Create(
43-
new ProducerConfig(producerConfig.StreamSystem, producerConfig.Stream)
44-
{
45-
_reference = producerConfig.Reference,
46-
ConfirmationHandler = producerConfig.ConfirmationHandler,
47-
ReconnectStrategy = producerConfig.ReconnectStrategy,
48-
ClientProvidedName = producerConfig.ClientProvidedName,
49-
SuperStreamConfig = producerConfig.SuperStreamConfig,
50-
MaxInFlight = producerConfig.MaxInFlight,
51-
MessagesBufferSize = producerConfig.MessagesBufferSize,
52-
TimeoutMessageAfter = producerConfig.TimeoutMessageAfter,
53-
Filter = producerConfig.Filter,
54-
Identifier = producerConfig.Identifier,
55-
ResourceAvailableReconnectStrategy = producerConfig.ResourceAvailableReconnectStrategy,
56-
57-
}, logger)
42+
.Create(producerConfig, logger)
5843
.ConfigureAwait(false)
5944
};
6045
return x;

0 commit comments

Comments
 (0)