diff --git a/ngcp/recentcalls.lua b/ngcp/recentcalls.lua
index 201775f..9a53a2d 100644
--- a/ngcp/recentcalls.lua
+++ b/ngcp/recentcalls.lua
@@ -69,7 +69,8 @@ end
     end
 
     function NGCPRecentCalls:set_by_uuid(uuid, callid, start_time,
-                                            duration, caller, callee)
+                                            duration, caller, callee,
+                                            source)
         if not self._test_connection(self.central) then
             self.central = self._connect(self.config.central)
         end
@@ -77,15 +78,17 @@ end
                                         "start_time", start_time,
                                         "duration", duration,
                                         "caller", caller,
-                                        "callee", callee)
+                                        "callee", callee,
+                                        "source", source)
         if res then
             self.central:expire(uuid, self.config.expire)
         end
-        sr.log("info", string.format("central:hset[%s]=>[%s] callid: %s start_time: %s duration: %d caller: %s callee: %s expire: %d\n",
+        sr.log("info", string.format("central:hset[%s]=>[%s] callid: %s start_time: %s duration: %d caller: %s callee: %s caller_id: %s callee_id: %s expire: %d\n",
                                     uuid, tostring(res),
                                     callid,
                                     start_time, duration,
                                     caller, callee,
+                                    source,
                                     self.config.expire))
         return res
     end
diff --git a/tests/ngcp_recentcalls.lua b/tests/ngcp_recentcalls.lua
index 537b2fe..725e892 100644
--- a/tests/ngcp_recentcalls.lua
+++ b/tests/ngcp_recentcalls.lua
@@ -79,19 +79,22 @@ TestNGCPRecentCalls = {} --class
         local duration   = 11
         local caller     = "437712345"
         local callee     = "437754321"
+        local source     = "SIPWISE_1"
 
         self.central:ping() ;mc :returns(true)
         self.central:hmset(uuid, "callid", callid,
                                  "start_time", start_time,
                                  "duration", duration,
                                  "caller", caller,
-                                 "callee", callee) ;mc :returns(true)
+                                 "callee", callee,
+                                 "source", source) ;mc :returns(true)
         self.central:expire(uuid, ttl) ;mc :returns(1)
 
         mc:replay()
         local res = self.rcalls:set_by_uuid(uuid, callid,
                                             start_time, duration,
-                                            caller, callee)
+                                            caller, callee,
+                                            source)
         mc:verify()
 
         assertTrue(res)