INNER CODE UNIT · Go

messageChan

owlistic-notes/owlistic · src/backend/broker/consumer_test.go:52

	messageChan := make(chan *nats.Msg, 1)

	// Simulate reading a message and sending it to the channel
	go func() {
		msg, err := mockConsumer.ReadMessage(-1)
		if err != nil {
			t.Errorf("Failed to read message: %v", err)
			return
		}

		messageChan <- msg
	}()

	// Receive the message from the channel
	var receivedMsg Message
	select {
	case receivedMsg = <-messageChan:
		// Message received successfully

View source record →