diff --git a/tests/test_stasis_endpoints.c b/tests/test_stasis_endpoints.c
index e17a79e14c4a292df728bb43cfa7437fd9bd3326..85d4afd17ed2df456c5271a11cc75de9f9bd0944 100644
--- a/tests/test_stasis_endpoints.c
+++ b/tests/test_stasis_endpoints.c
@@ -239,16 +239,12 @@ AST_TEST_DEFINE(channel_messages)
 
 	ast_endpoint_add_channel(uut, chan);
 
-	actual_count = stasis_message_sink_wait_for_count(sink, 2,
+	actual_count = stasis_message_sink_wait_for_count(sink, 1,
 		STASIS_SINK_DEFAULT_WAIT);
-	ast_test_validate(test, 2 == actual_count);
+	ast_test_validate(test, 1 == actual_count);
 
 	msg = sink->messages[0];
 	type = stasis_message_type(msg);
-	ast_test_validate(test, ast_channel_snapshot_type() == type);
-
-	msg = sink->messages[1];
-	type = stasis_message_type(msg);
 	ast_test_validate(test, ast_endpoint_snapshot_type() == type);
 	actual_snapshot = stasis_message_data(msg);
 	ast_test_validate(test, 1 == actual_snapshot->num_channels);
@@ -256,20 +252,20 @@ AST_TEST_DEFINE(channel_messages)
 	ast_hangup(chan);
 	chan = NULL;
 
-	actual_count = stasis_message_sink_wait_for_count(sink, 5,
+	actual_count = stasis_message_sink_wait_for_count(sink, 4,
 		STASIS_SINK_DEFAULT_WAIT);
-	ast_test_validate(test, 5 == actual_count);
+	ast_test_validate(test, 4 == actual_count);
 
-	msg = sink->messages[2];
+	msg = sink->messages[1];
 	type = stasis_message_type(msg);
 	ast_test_validate(test, ast_channel_snapshot_type() == type);
 
 	/* The ordering of the cache clear and endpoint snapshot are
 	 * unspecified */
-	msg = sink->messages[3];
+	msg = sink->messages[2];
 	if (stasis_message_type(msg) == stasis_cache_clear_type()) {
 		/* Okay; the next message should be the endpoint snapshot */
-		msg = sink->messages[4];
+		msg = sink->messages[3];
 	}
 
 	type = stasis_message_type(msg);