first successful live test

This commit is contained in:
Radu Ioan Fericean
2015-07-01 20:34:32 +03:00
parent 02dc95d815
commit e7f0b617ec
3 changed files with 14 additions and 3 deletions

View File

@@ -371,7 +371,7 @@ func startPubSubServer(chanDone chan struct{}) {
exitChan <- true
return
}
server.RpcRegisterName("PubSub", pubSubServer)
server.RpcRegisterName("PubSubV1", pubSubServer)
close(chanDone)
}

View File

@@ -258,7 +258,7 @@ func (self CgrJsonCfg) HistAgentJsonCfg() (*HistAgentJsonCfg, error) {
}
func (self CgrJsonCfg) PubSubServJsonCfg() (*PubSubServJsonCfg, error) {
rawCfg, hasKey := self[HISTSERV_JSN]
rawCfg, hasKey := self[PUBSUBSERV_JSN]
if !hasKey {
return nil, nil
}
@@ -270,7 +270,7 @@ func (self CgrJsonCfg) PubSubServJsonCfg() (*PubSubServJsonCfg, error) {
}
func (self CgrJsonCfg) PubSubAgentJsonCfg() (*PubSubAgentJsonCfg, error) {
rawCfg, hasKey := self[HISTAGENT_JSN]
rawCfg, hasKey := self[PUBSUBAGENT_JSN]
if !hasKey {
return nil, nil
}

View File

@@ -17,4 +17,15 @@
"scheduler": {
"enabled": true, // start Scheduler service: <true|false>
},
"pubsub_server": {
"enabled": true, // starts pubsub service: <true|false>.
"save_interval": "1m", // interval to save subscribers
},
"pubsub_agent": {
"enabled": true, // starts pubsub as a client: <true|false>.
"server": "internal", // address where to reach the master pubsub server: <internal|x.y.z.y:1234>
},
}