revert

#431
there tests doesn't pass with #431

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

Author: Gsantomaggio

pkg/stream/producer.go

@@ -218,8 +218,8 @@ func (producer *Producer) NotifyPublishConfirmation() ChannelPublishConfirm {
 
 // NotifyClose returns a channel that receives the close event of the producer.
 func (producer *Producer) NotifyClose() ChannelClose {
-	producer.mutex.Lock()
-	defer producer.mutex.Unlock()
+	// producer.mutex.Lock()
+	//defer producer.mutex.Unlock()
 	ch := make(chan Event, 1)
 	producer.closeHandler = ch
 	return ch
@@ -678,8 +678,8 @@ func (producer *Producer) close(reason Event) error {
 	reason.StreamName = producer.GetStreamName()
 	reason.Name = producer.GetName()
 
-	producer.mutex.Lock()
-	defer producer.mutex.Unlock()
+	// producer.mutex.Lock()
+	//defer producer.mutex.Unlock()
 
 	if producer.closeHandler != nil {
 		producer.closeHandler <- reason