diff --git a/public/bundle.js b/public/bundle.js
index 228a74b..a181dae 100644
--- a/public/bundle.js
+++ b/public/bundle.js
@@ -20359,8 +20359,7 @@ module.exports = {
 const io = require('socket.io-client')
 const mediasoupClient = require('mediasoup-client')
 const urlParams = new URLSearchParams(location.search);
-const config = require('./config');
-const { connect } = require('socket.io-client');
+const config = require('./config')
 console.log('[CONFIG]', config);
 
 const ASSET_ID = parseInt(urlParams.get('assetId')) || null;
@@ -20456,7 +20455,7 @@ setTimeout(() => {
 
     socket.on('new-producer', ({ callId }) => {
       console.log(`🟢 new-producer | callId: ${callId} | Ready to consume`);
-      // consume()
+        // consume()
     })
   }
   
@@ -20580,10 +20579,6 @@ const createDevice = async () => {
       routerRtpCapabilities: rtpCapabilities
     })
 
-    device.observer.on("newtransport", (transport) => {
-      consume()
-    })
-
     console.log('Device RTP Capabilities', device.rtpCapabilities)
     console.log('[createDevice] device', device);
     
@@ -20740,6 +20735,7 @@ const connectSendTransport = async () => {
   // Enable Close call button
   const closeCallBtn = document.getElementById('btnCloseCall');
   closeCallBtn.removeAttribute('disabled');
+  consume()
 }
 
 const createRecvTransport = async () => {
@@ -20779,7 +20775,11 @@ const createRecvTransport = async () => {
         errback(error)
       }
     })
-    connectRecvTransport()
+
+    consumerTransport.observer.on("newproducer", (producer) => {
+      console.log("new producer created [id:%s]", producer.id);
+    });
+    // connectRecvTransport()
   })
 }
 
diff --git a/public/index.js b/public/index.js
index 97d1f1b..55e3226 100644
--- a/public/index.js
+++ b/public/index.js
@@ -1,8 +1,7 @@
 const io = require('socket.io-client')
 const mediasoupClient = require('mediasoup-client')
 const urlParams = new URLSearchParams(location.search);
-const config = require('./config');
-const { connect } = require('socket.io-client');
+const config = require('./config')
 console.log('[CONFIG]', config);
 
 const ASSET_ID = parseInt(urlParams.get('assetId')) || null;
@@ -98,7 +97,7 @@ setTimeout(() => {
 
     socket.on('new-producer', ({ callId }) => {
       console.log(`🟢 new-producer | callId: ${callId} | Ready to consume`);
-      // consume()
+        // consume()
     })
   }
   
@@ -222,10 +221,6 @@ const createDevice = async () => {
       routerRtpCapabilities: rtpCapabilities
     })
 
-    device.observer.on("newtransport", (transport) => {
-      consume()
-    })
-
     console.log('Device RTP Capabilities', device.rtpCapabilities)
     console.log('[createDevice] device', device);
     
@@ -382,6 +377,7 @@ const connectSendTransport = async () => {
   // Enable Close call button
   const closeCallBtn = document.getElementById('btnCloseCall');
   closeCallBtn.removeAttribute('disabled');
+  consume()
 }
 
 const createRecvTransport = async () => {
@@ -421,7 +417,11 @@ const createRecvTransport = async () => {
         errback(error)
       }
     })
-    connectRecvTransport()
+
+    consumerTransport.observer.on("newproducer", (producer) => {
+      console.log("new producer created [id:%s]", producer.id);
+    });
+    // connectRecvTransport()
   })
 }