diff --git a/src/subscriptions.c b/src/subscriptions.c
index 8dff4acf..548fa7e9 100644
--- a/src/subscriptions.c
+++ b/src/subscriptions.c
@@ -643,6 +643,8 @@ subscription_set_speed ( th_subscription_t *s, int speed )
   streaming_message_t *sm;
   service_t *t = s->ths_service;
 
+  if (!t) return;
+
   pthread_mutex_lock(&t->s_stream_mutex);
 
   sm = streaming_msg_create_code(SMT_SPEED, speed);
@@ -661,6 +663,8 @@ subscription_set_skip ( th_subscription_t *s, const streaming_skip_t *skip )
   streaming_message_t *sm;
   service_t *t = s->ths_service;
 
+  if (!t) return;
+
   pthread_mutex_lock(&t->s_stream_mutex);
 
   sm = streaming_msg_create(SMT_SKIP);