Set Event Source according to O-RAN Spec (redhat-cne#98)

Signed-off-by: Jack Ding <[email protected]>
jzding · Jul 16, 2024 · 19a18fd · 19a18fd
1 parent f435c15
commit 19a18fd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/event/event_ce.go b/pkg/event/event_ce.go
@@ -40,11 +40,11 @@ func (e *Event) NewCloudEvent(ps *pubsub.PubSub) (*cloudevent.Event, error) {
 }
 
 // NewCloudEvent create new cloud event from cloud native events and pubsub
-func (e *Event) NewCloudEventV2(ps *pubsub.PubSub) (*cloudevent.Event, error) {
+func (e *Event) NewCloudEventV2() (*cloudevent.Event, error) {
 	ce := cloudevent.NewEvent(cloudevent.VersionV1)
 	ce.SetTime(e.GetTime())
 	ce.SetType(e.Type)
-	ce.SetSource(ps.Resource) // bus address
+	ce.SetSource(e.Source)
 	ce.SetSpecVersion(cloudevent.VersionV1)
 	ce.SetID(uuid.New().String())
 	if err := ce.SetData("", e.GetData()); err != nil {