VOL-3657 support stack id in rpc events
Change-Id: Ie94fc7aa6f3a4c58803156f75d29ecad7f11e601
diff --git a/rw_core/core/device/manager.go b/rw_core/core/device/manager.go
index 02eaf11..9d9f933 100755
--- a/rw_core/core/device/manager.go
+++ b/rw_core/core/device/manager.go
@@ -61,7 +61,7 @@
}
//NewManagers creates the Manager and the Logical Manager.
-func NewManagers(dbPath *model.Path, adapterMgr *adapter.Manager, kmp kafka.InterContainerProxy, endpointMgr kafka.EndpointManager, coreTopic, coreInstanceID string, defaultCoreTimeout time.Duration, eventProxy *events.EventProxy) (*Manager, *LogicalManager) {
+func NewManagers(dbPath *model.Path, adapterMgr *adapter.Manager, kmp kafka.InterContainerProxy, endpointMgr kafka.EndpointManager, coreTopic, coreInstanceID string, defaultCoreTimeout time.Duration, eventProxy *events.EventProxy, stackID string) (*Manager, *LogicalManager) {
deviceMgr := &Manager{
rootDevices: make(map[string]bool),
kafkaICProxy: kmp,
@@ -71,13 +71,13 @@
dProxy: dbPath.Proxy("devices"),
adapterMgr: adapterMgr,
defaultTimeout: defaultCoreTimeout,
- RPCEventManager: event.NewRPCEventManager(eventProxy, coreInstanceID),
+ RPCEventManager: event.NewRPCEventManager(eventProxy, coreInstanceID, stackID),
deviceLoadingInProgress: make(map[string][]chan int),
}
deviceMgr.stateTransitions = state.NewTransitionMap(deviceMgr)
logicalDeviceMgr := &LogicalManager{
- Manager: event.NewManager(eventProxy, coreInstanceID),
+ Manager: event.NewManager(eventProxy, coreInstanceID, stackID),
deviceMgr: deviceMgr,
kafkaICProxy: kmp,
dbPath: dbPath,