tests

func AssertAllMessagesReceived(t *testing.T, sent message.Messages, received message.Messages) bool

func AssertMessagesMetadata(t *testing.T, key string, expectedValues map[string]string, received []*message.Message) bool

func AssertMessagesPayloads(
	t *testing.T,
	expectedPayloads map[string]interface{},
	received []*message.Message,
) bool

func MissingMessages(expected message.Messages, received message.Messages) []string