diff --git a/daemon/redis.c b/daemon/redis.c
index cb1b674f4..d0ba67c33 100644
--- a/daemon/redis.c
+++ b/daemon/redis.c
@@ -674,6 +674,8 @@ static int redis_streams(struct call *c, struct redis_list *streams) {
 		atomic64_set_na(&ps->last_packet, time(NULL));
 		if (redis_hash_get_unsigned((unsigned int *) &ps->ps_flags, rh, "ps_flags"))
 			return -1;
+		if (redis_hash_get_unsigned((unsigned int *) &ps->component, rh, "component"))
+			return -1;
 		if (redis_hash_get_endpoint(&ps->endpoint, rh, "endpoint"))
 			return -1;
 		if (redis_hash_get_endpoint(&ps->advertised_endpoint, rh, "advertised_endpoint"))
@@ -1318,7 +1320,7 @@ void redis_update(struct call *c, struct redis *r) {
 
 		redis_pipe(r, "HMSET stream-"PB"-%u media %u sfd %u rtp_sink %u "
 			"rtcp_sink %u rtcp_sibling %u last_packet "UINT64F" "
-			"ps_flags %u",
+			"ps_flags %u component %u",
 			STR(&c->callid), ps->unique_id,
 			ps->media->unique_id,
 			ps->selected_sfd ? ps->selected_sfd->unique_id : -1,
@@ -1326,7 +1328,8 @@ void redis_update(struct call *c, struct redis *r) {
 			ps->rtcp_sink ? ps->rtcp_sink->unique_id : -1,
 			ps->rtcp_sibling ? ps->rtcp_sibling->unique_id : -1,
 			atomic64_get(&ps->last_packet),
-			ps->ps_flags);
+			ps->ps_flags,
+			ps->component);
 		redis_update_endpoint(r, "stream", &c->callid, ps->unique_id, "endpoint", &ps->endpoint);
 		redis_update_endpoint(r, "stream", &c->callid, ps->unique_id, "advertised_endpoint",
 				&ps->advertised_endpoint);