VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto
Change-Id: I7bf9abbdb590ac193b1d769f46cddc01b0ac2efb
diff --git a/rw_core/core/adapter/manager.go b/rw_core/core/adapter/manager.go
index 015e32d..08c0e04 100644
--- a/rw_core/core/adapter/manager.go
+++ b/rw_core/core/adapter/manager.go
@@ -119,13 +119,13 @@
return nil
}
-func (aMgr *Manager) updateLastAdapterCommunication(adapterID string, timestamp int64) {
+func (aMgr *Manager) updateLastAdapterCommunication(adapterID string, timestamp time.Time) {
aMgr.lockAdaptersMap.RLock()
adapterAgent, have := aMgr.adapterAgents[adapterID]
aMgr.lockAdaptersMap.RUnlock()
if have {
- adapterAgent.updateCommunicationTime(time.Unix(timestamp/1000, timestamp%1000*1000))
+ adapterAgent.updateCommunicationTime(timestamp)
}
}