summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--main/stasis_channels.c8
1 files changed, 5 insertions, 3 deletions
diff --git a/main/stasis_channels.c b/main/stasis_channels.c
index 1efc51dbb..0fbbf5d96 100644
--- a/main/stasis_channels.c
+++ b/main/stasis_channels.c
@@ -969,14 +969,17 @@ int ast_stasis_channels_init(void)
if (!channel_cache_all) {
return -1;
}
- STASIS_MESSAGE_TYPE_INIT(ast_channel_agent_login_type);
- STASIS_MESSAGE_TYPE_INIT(ast_channel_agent_logoff_type);
+ res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_agent_login_type);
+ res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_agent_logoff_type);
channel_cache_by_name = stasis_cache_create(channel_snapshot_get_name);
if (!channel_cache_by_name) {
return -1;
}
+ /* This should be initialized before the caching topic */
+ res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_snapshot_type);
+
channel_by_name_topic = stasis_caching_topic_create(
stasis_cp_all_topic(channel_cache_all),
channel_cache_by_name);
@@ -984,7 +987,6 @@ int ast_stasis_channels_init(void)
return -1;
}
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_snapshot_type);
res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_dial_type);
res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_varset_type);
res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_user_event_type);