diff --git a/transport/memory/memory.go b/transport/memory/memory.go
index 274e98c9..b1f4f071 100644
--- a/transport/memory/memory.go
+++ b/transport/memory/memory.go
@@ -84,8 +84,8 @@ func (ms *memorySocket) Send(m *transport.Message) error {
 }
 
 func (ms *memorySocket) Close() error {
-	ms.RLock()
-	defer ms.RUnlock()
+	ms.Lock()
+	defer ms.Unlock()
 	select {
 	case <-ms.exit:
 		return nil