INNER CODE UNIT · Go

receivedMsg

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

	case receivedMsg = <-messageChan:
		// Message received successfully
	case <-time.After(1 * time.Second):
		t.Fatal("Timed out waiting for message")
	}

	// Verify the message content
	if receivedMsg.Subject != "mock_topic" ||
		string(receivedMsg.Data) != "mock_value" {
		t.Errorf("Unexpected message content: %+v", receivedMsg)
	}
}

View source record →