diff --git a/erpnext/erpnext_integrations/exotel_integration.py b/erpnext/erpnext_integrations/exotel_integration.py
index f91f757..10d533c 100644
--- a/erpnext/erpnext_integrations/exotel_integration.py
+++ b/erpnext/erpnext_integrations/exotel_integration.py
@@ -14,16 +14,15 @@
 	if status == 'free':
 		return
 
-	call_log = get_call_log(kwargs)
+	create_call_log(kwargs)
 
 @frappe.whitelist(allow_guest=True)
 def handle_end_call(*args, **kwargs):
-	call_log = update_call_log(kwargs, 'Completed')
+	update_call_log(kwargs, 'Completed')
 
 @frappe.whitelist(allow_guest=True)
 def handle_missed_call(*args, **kwargs):
-	call_log = update_call_log(kwargs, 'Missed')
-	frappe.publish_realtime('call_disconnected', call_log)
+	update_call_log(kwargs, 'Missed')
 
 def update_call_log(call_payload, status):
 	call_log = get_call_log(call_payload, False)
@@ -35,7 +34,6 @@
 		frappe.db.commit()
 		return call_log
 
-
 def get_call_log(call_payload, create_new_if_not_found=True):
 	call_log = frappe.get_all('Call Log', {
 		'id': call_payload.get('CallSid'),
@@ -54,6 +52,8 @@
 		frappe.db.commit()
 		return call_log
 
+create_call_log = get_call_log
+
 @frappe.whitelist()
 def get_call_status(call_id):
 	endpoint = get_exotel_endpoint('Calls/{call_id}.json'.format(call_id=call_id))