diff --git a/streaming/stream_session.cc b/streaming/stream_session.cc
index 0506b7dcbb..92d361f1f8 100644
--- a/streaming/stream_session.cc
+++ b/streaming/stream_session.cc
@@ -112,6 +112,18 @@ void stream_session::on_initialization_complete() {
     }
 }
 
+void stream_session::on_error() {
+#if 0
+    //logger.error("[Stream #{}] Streaming error occurred", planId(), e);
+    // send session failure message
+    if (handler.is_outgoing_connected()) {
+       handler.sendMessage(session_failed_message());
+    }
+#endif
+    // fail session
+    close_session(stream_session_state::FAILED);
+}
+
 void stream_session::prepare(std::vector<stream_request> requests, std::vector<stream_summary> summaries) {
     // prepare tasks
     set_state(stream_session_state::PREPARING);
diff --git a/streaming/stream_session.hh b/streaming/stream_session.hh
index f5fecfb7af..79038317c2 100644
--- a/streaming/stream_session.hh
+++ b/streaming/stream_session.hh
@@ -417,22 +417,12 @@ public:
      */
     void on_initialization_complete();
 
-#if 0
     /**l
      * Call back for handling exception during streaming.
      *
      * @param e thrown exception
      */
-    public void onError(Throwable e)
-    {
-        logger.error("[Stream #{}] Streaming error occurred", planId(), e);
-        // send session failure message
-        if (handler.isOutgoingConnected())
-            handler.sendMessage(new SessionFailedMessage());
-        // fail session
-        close_session(stream_session_state::FAILED);
-    }
-#endif
+    void on_error();
 
     /**
      * Prepare this session for sending/receiving files.