Loading go-apps/meep-vis/server/vis.go +24 −8 Original line number Diff line number Diff line Loading @@ -1720,6 +1720,7 @@ func v2xNotify(v2xMessage []byte, v2xType int32, longitude *float32, latitude *f log.Info("v2xNotify: i: ", i) log.Info("v2xNotify: sub", sub) if sub.FilterCriteria != nil && findMsgTypeId(sub.FilterCriteria.MsgType, msgType) { if sub.Links != nil { v2xMsgNotification.Links = &V2xMsgNotificationLinks{ Subscription: sub.Links.Self, Loading @@ -1731,3 +1732,18 @@ func v2xNotify(v2xMessage []byte, v2xType int32, longitude *float32, latitude *f sendV2xMsgNotification(notifyUrl, v2xMsgNotification) } } } func findMsgTypeId(list []MsgType, item MsgType) bool { if len(list) == 0 { return false } for _, v := range list { if v == item { return true } } return false } go-packages/meep-vis-traffic-mgr/amqp.go +1 −0 Original line number Diff line number Diff line Loading @@ -18,6 +18,7 @@ import ( //"encoding/hex" "net/url" //"errors" log "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-logger" Loading Loading
go-apps/meep-vis/server/vis.go +24 −8 Original line number Diff line number Diff line Loading @@ -1720,6 +1720,7 @@ func v2xNotify(v2xMessage []byte, v2xType int32, longitude *float32, latitude *f log.Info("v2xNotify: i: ", i) log.Info("v2xNotify: sub", sub) if sub.FilterCriteria != nil && findMsgTypeId(sub.FilterCriteria.MsgType, msgType) { if sub.Links != nil { v2xMsgNotification.Links = &V2xMsgNotificationLinks{ Subscription: sub.Links.Self, Loading @@ -1731,3 +1732,18 @@ func v2xNotify(v2xMessage []byte, v2xType int32, longitude *float32, latitude *f sendV2xMsgNotification(notifyUrl, v2xMsgNotification) } } } func findMsgTypeId(list []MsgType, item MsgType) bool { if len(list) == 0 { return false } for _, v := range list { if v == item { return true } } return false }
go-packages/meep-vis-traffic-mgr/amqp.go +1 −0 Original line number Diff line number Diff line Loading @@ -18,6 +18,7 @@ import ( //"encoding/hex" "net/url" //"errors" log "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-logger" Loading