Function wmSendMessage

watch_manager_test.go:50–54

wmSendMessage sends a message and asserts no error

(t *testing.T, wm *watchManager, bucket, key string, value []byte)

// wmSendMessage sends a message and asserts no error
func wmSendMessage(t *testing.T, wm *watchManager, bucket, key string, value []byte) {
	message := NewMessage(bucket, key, value, DataFlag(0), uint64(time.Now().Unix()), MessageOptions{Priority: MessagePriorityMedium})
	err := wm.sendMessage(message)
	assert.NoError(t, err)
}

// wmSendMessages sends multiple messages to the same bucket/key
func wmSendMessages(t *testing.T, wm *watchManager, bucket, key string, count int) {