diff --git a/daemon/call.c b/daemon/call.c
index 8d70e84ee..1a782ade3 100644
--- a/daemon/call.c
+++ b/daemon/call.c
@@ -1005,7 +1005,7 @@ void call_media_state_machine(struct call_media *m) {
 		call_stream_state_machine(l->data);
 }
 
-static int __init_stream(struct packet_stream *ps) {
+int __init_stream(struct packet_stream *ps) {
 	struct call_media *media = ps->media;
 	struct call *call = ps->call;
 	int dtls_active = -1;
diff --git a/daemon/redis.c b/daemon/redis.c
index 8686a8004..d6f7dbcd3 100644
--- a/daemon/redis.c
+++ b/daemon/redis.c
@@ -1420,6 +1420,8 @@ static int json_link_streams(struct call *c, struct redis_list *streams,
 
 		if (ps->media)
 			__rtp_stats_update(ps->rtp_stats, ps->media->codecs_recv);
+
+		__init_stream(ps);
 	}
 
 	return 0;
diff --git a/include/call.h b/include/call.h
index ac5dba04e..608dc4798 100644
--- a/include/call.h
+++ b/include/call.h
@@ -435,6 +435,7 @@ void add_total_calls_duration_in_interval(struct timeval *interval_tv);
 
 void payload_type_free(struct rtp_payload_type *p);
 void __rtp_stats_update(GHashTable *dst, GHashTable *src);
+int __init_stream(struct packet_stream *ps);
 
 const struct rtp_payload_type *__rtp_stats_codec(struct call_media *m);