230 change stream options when already created

[dc1992]

In this PR I removed the boot parameter that was used to activate the deduplication. From now, to activate the deduplication you just need to define a publisherRef value.

I also fixed a race condition when sending multiple messages concurrently with deduplication actived.

[Gsantomaggio]

To use the deduplication, the client needs to expose an API to pass the publishingid; otherwise it does not make sense :)

See for example the Go-client:
https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/main/examples/deduplication/deduplication.go#L66-L84
where the user must provide the id for each message to avoid duplications

or the .NET client where with the message you can pass the id the API
https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/blob/main/RabbitMQ.Stream.Client/Reliable/DeduplicatingProducer.cs#L71

[dc1992]

To use the deduplication, the client needs to expose an API to pass the publishingid; otherwise it does not make sense :)

See for example the Go-client: https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/main/examples/deduplication/deduplication.go#L66-L84 where the user must provide the id for each message to avoid duplications

or the .NET client where with the message you can pass the id the API https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/blob/main/RabbitMQ.Stream.Client/Reliable/DeduplicatingProducer.cs#L71

Ok, but passing publishingid from outside is not mandatory, is it?
If you don't pass it from outside the client takes the next id increasing its own by one, right?

[Gsantomaggio]

Ok, but passing publishingid from outside is not mandatory, is it?

It is mandatory else the deduplication won't work. In this implementation, deduplication works like the standard producer.

[Gsantomaggio]

Thank you