VOL-1176: Ported callback mechanism
- Updated some files with the license block
Change-Id: I61db400b3a72c4915f4f3f17cc7a110313c2d25e
diff --git a/db/model/event_bus.go b/db/model/event_bus.go
index c20eac3..6afc63b 100644
--- a/db/model/event_bus.go
+++ b/db/model/event_bus.go
@@ -44,7 +44,12 @@
return bus
}
-func (bus *EventBus) Advertise(eventType CallbackType, data interface{}, hash string) {
+//func (bus *EventBus) Advertise(eventType CallbackType, data interface{}, hash string) {
+func (bus *EventBus) Advertise(args ...interface{}) interface{} {
+ eventType := args[0].(CallbackType)
+ data := args[1]
+ hash := args[2].(string)
+
if _, ok := IGNORED_CALLBACKS[eventType]; ok {
fmt.Printf("ignoring event - type:%s, data:%+v\n", eventType, data)
}
@@ -75,4 +80,6 @@
}
bus.client.Publish(bus.topic, event)
+
+ return nil
}