From db4bf4dfbc520cca1b1bf642eaf3e324d4f3fc54 Mon Sep 17 00:00:00 2001 From: DanB Date: Mon, 5 Sep 2016 16:28:00 +0200 Subject: [PATCH] DiameterAgent - Empty the pubsub interface so we can later check it if nil --- agents/dmtagent.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/agents/dmtagent.go b/agents/dmtagent.go index 5de24273e..21bf137b0 100644 --- a/agents/dmtagent.go +++ b/agents/dmtagent.go @@ -19,6 +19,7 @@ package agents import ( "fmt" + "reflect" "strconv" "strings" "sync" @@ -34,6 +35,9 @@ import ( func NewDiameterAgent(cgrCfg *config.CGRConfig, smg rpcclient.RpcClientConnection, pubsubs rpcclient.RpcClientConnection) (*DiameterAgent, error) { da := &DiameterAgent{cgrCfg: cgrCfg, smg: smg, pubsubs: pubsubs, connMux: new(sync.Mutex)} + if reflect.ValueOf(da.pubsubs).IsNil() { + da.pubsubs = nil // Empty it so we can check it later + } dictsDir := cgrCfg.DiameterAgentCfg().DictionariesDir if len(dictsDir) != 0 { if err := loadDictionaries(dictsDir, "DiameterAgent"); err != nil {