update version to 1.0.0-rc11 and fix StoreCustomOffset

Author: Gsantomaggio

README.md

@@ -44,7 +44,7 @@ Go client for [RabbitMQ Stream Queues](https://github.com/rabbitmq/rabbitmq-serv
 ### Installing
 
 ```shell
-go get -u github.com/rabbitmq/rabbitmq-stream-go-client@v1.0.0-rc10
+go get -u github.com/rabbitmq/rabbitmq-stream-go-client@v1.0.0-rc11
 ```
 
 imports:

VERSION

@@ -1 +1 @@
-1.0.0-rc10
+1.0.0-rc11

pkg/stream/constants.go

@@ -19,7 +19,7 @@ const (
 const initBufferPublishSize = 2 + 2 + 1 + 4
 
 const (
-	ClientVersion = "1.0.0-rc10"
+	ClientVersion = "1.0.0-rc11"
 
 	commandDeclarePublisher       = 1
 	commandPublish                = 2

pkg/stream/consumer.go

@@ -254,6 +254,9 @@ func (consumer *Consumer) StoreOffset() error {
 	return consumer.internalStoreOffset()
 }
 func (consumer *Consumer) StoreCustomOffset(offset int64) error {
+	consumer.mutex.Lock()
+	defer consumer.mutex.Unlock()
+
 	if consumer.lastStoredOffset < offset {
 		consumer.lastStoredOffset = offset
 		return consumer.writeOffsetToSocket(offset)