1 files changed, 14 insertions, 3 deletions
diff --git a/src/pipelines.c b/src/pipelines.c
index b241cde..3fe09e8 100644
--- a/src/pipelines.c
+++ b/src/pipelines.c
@@ -263,12 +263,23 @@ GstElement* create_sender_pipeline(options_t* opt, struct udp_sinks *udp)
       return NULL;
   }
 
-  log_printf(DEBUG, "pipeline created successfully!");
+  log_printf(DEBUG, "sender pipeline created successfully!");
   return pipeline;
 }
 
 GstElement* create_receiver_pipeline(options_t* opt, struct udp_sources *udp)
 {
-  log_printf(ERROR, "Receiver Mode is not yet implemented!");
-  return NULL;
+  GstElement *pipeline = gst_pipeline_new ("sydra");
+  if(!pipeline) {
+    log_printf(ERROR, "Creating pipeline failed!");
+    return NULL;
+  }
+  GstElement *rtp = sydra_create_element("rtpbin", "rtpbin");
+  if(!rtp || !gst_bin_add(GST_BIN(pipeline), rtp)) {
+    return NULL;
+  }
+  log_printf(DEBUG, "rtpbin created successfully!");
+
+  log_printf(DEBUG, "receiver pipeline created successfully!");
+  return pipeline;
 }