TESTPOINT_DECL(consumerd_thread_channel);
TESTPOINT_DECL(consumerd_thread_metadata);
TESTPOINT_DECL(consumerd_thread_data);
+TESTPOINT_DECL(consumerd_thread_data_poll);
TESTPOINT_DECL(consumerd_thread_sessiond);
TESTPOINT_DECL(consumerd_thread_metadata_timer);