VOL-3734 optimise rpc events to be send to queue and then to kafka from the queue
Change-Id: I5e068722412b6d9526760900d9173aaf51e00946
diff --git a/rw_core/core/device/logical_manager.go b/rw_core/core/device/logical_manager.go
index e8e28f7..39342da 100644
--- a/rw_core/core/device/logical_manager.go
+++ b/rw_core/core/device/logical_manager.go
@@ -568,8 +568,8 @@
if err != nil {
logger.Errorw(ctx, "failed-to-receive-packet-out", log.Fields{"error": err})
// we do not have the resource Id here due to error in the packet, setting to empty
- go ldMgr.SendRPCEvent(pktCtx, "", err.Error(), nil,
- "RPC_ERROR_RAISE_EVENT", voltha.EventCategory_COMMUNICATION, nil, time.Now().UnixNano())
+ ldMgr.SendRPCEvent(pktCtx, "", err.Error(), nil,
+ "RPC_ERROR_RAISE_EVENT", voltha.EventCategory_COMMUNICATION, nil, time.Now().Unix())
continue
}