fix: Initialize queue in in-memory broker if the queue isn't found in…

… consume.

brokers/in-memory/broker.go

@@ -24,9 +24,18 @@ func New() *Broker {
 
 func (r *Broker) Consume(ctx context.Context, work chan []byte, queue string) {
 	r.mu.RLock()
-	ch := r.queues[queue]
+	ch, ok := r.queues[queue]
 	r.mu.RUnlock()
 
+	// If the queue isn't found, make a queue.
+	if !ok {
+		ch = make(chan []byte, 100)
+		r.mu.Lock()
+		r.queues[queue] = ch
+		r.mu.Unlock()
+
+	}
+
 	for {
 		select {
 		case <-ctx.Done():