From 56cd7b2aa8c9d931b147202a7a82bcbf4eb19691 Mon Sep 17 00:00:00 2001 From: DanB Date: Tue, 4 Jul 2017 12:48:43 +0200 Subject: [PATCH] Updating fsock with slice for event filters --- glide.lock | 2 +- sessionmanager/fssessionmanager.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/glide.lock b/glide.lock index 403d1bd76..a99c60b93 100644 --- a/glide.lock +++ b/glide.lock @@ -12,7 +12,7 @@ imports: - name: github.com/cgrates/aringo version: 47cdb110c5ff42bddf2b801dc5ae8ceb15d2d602 - name: github.com/cgrates/fsock - version: a8ffdbdfc8440016df008ba91e6f05f806d7a69f + version: 5b60f0d72ff4f8885289bffab55435e5b8adfb55 - name: github.com/cgrates/kamevapi version: a376b1f937ba959857929fa3e111c0f3243278c0 - name: github.com/cgrates/osipsdagram diff --git a/sessionmanager/fssessionmanager.go b/sessionmanager/fssessionmanager.go index 3839beb7e..08c3ce2b8 100644 --- a/sessionmanager/fssessionmanager.go +++ b/sessionmanager/fssessionmanager.go @@ -292,7 +292,7 @@ func (sm *FSSessionManager) onChannelHangupComplete(ev engine.Event) { // Connects to the freeswitch mod_event_socket server and starts // listening for events. func (sm *FSSessionManager) Connect() error { - eventFilters := map[string]string{"Call-Direction": "inbound"} + eventFilters := map[string][]string{"Call-Direction": []string{"inbound"}} errChan := make(chan error) for _, connCfg := range sm.cfg.EventSocketConns { connId := utils.GenUUID() @@ -311,7 +311,7 @@ func (sm *FSSessionManager) Connect() error { } }() if fsSenderPool, err := fsock.NewFSockPool(5, connCfg.Address, connCfg.Password, 1, sm.cfg.MaxWaitConnection, - make(map[string][]func(string, string)), make(map[string]string), utils.Logger.GetSyslog(), connId); err != nil { + make(map[string][]func(string, string)), make(map[string][]string), utils.Logger.GetSyslog(), connId); err != nil { return fmt.Errorf("Cannot connect FreeSWITCH senders pool, error: %s", err.Error()) } else if fsSenderPool == nil { return errors.New("Cannot connect FreeSWITCH senders pool.")