diff --git a/brokers/in-memory/broker.go b/brokers/in-memory/broker.go
index 1ebaabe..2467d07 100644
--- a/brokers/in-memory/broker.go
+++ b/brokers/in-memory/broker.go
@@ -46,9 +46,7 @@ func (r *Broker) Consume(ctx context.Context, work chan []byte, queue string) {
 			r.pending[queue] = r.pending[queue][1:]
 			r.pmu.Unlock()
 
-			r.mu.RLock()
 			work <- d
-			r.mu.RUnlock()
 		}
 	}
 }