diff --git a/src/zm_stream.cpp b/src/zm_stream.cpp
index 8ae9f5549..8002c4f18 100644
--- a/src/zm_stream.cpp
+++ b/src/zm_stream.cpp
@@ -44,7 +44,11 @@ bool StreamBase::loadMonitor( int monitor_id ) {
     Fatal( "Unable to load monitor id %d for streaming", monitor_id );
     return( false );
   }
-  monitor->connect();
+  if ( ! monitor->connect() ) {
+    Fatal( "Unable to connect to monitor id %d for streaming", monitor_id );
+    return( false );
+  }
+    
   return( true );
 }