Stephane Barbarie | 4a2564d | 2018-07-26 11:02:58 -0400 | [diff] [blame^] | 1 | package model |
2 | |||||
3 | import ( | ||||
4 | "fmt" | ||||
5 | "github.com/opencord/voltha/protos/go/voltha" | ||||
6 | ) | ||||
7 | |||||
8 | type EventBusClient struct { | ||||
9 | } | ||||
10 | |||||
11 | func NewEventBusClient() *EventBusClient { | ||||
12 | return &EventBusClient{} | ||||
13 | } | ||||
14 | |||||
15 | func (ebc *EventBusClient) Publish(topic string, event voltha.ConfigEvent) { | ||||
16 | fmt.Printf("publishing event:%+v, topic:%s\n", event, topic) | ||||
17 | } |