INNER CODE UNIT · Go

TestStartConsumer

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

func TestStartConsumer(t *testing.T) {
	// Create a mock consumer with test messages
	mockConsumer := NewMockConsumer()

	// Create channel to receive messages
	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
	}()

View source record →