diff --git a/config/config_defaults.go b/config/config_defaults.go index ff6daf545..5c54707d3 100755 --- a/config/config_defaults.go +++ b/config/config_defaults.go @@ -52,6 +52,8 @@ const CGRATES_CFG_JSON = ` "digest_equal": ":", // equal symbol used in case of digests "rsr_separator": ";", // separator used within RSR fields "max_parallel_conns": 100, // the maximum number of connection used by the *parallel strategy + "concurrent_requests": 0, // maximum concurrent request allowed ( 0 to disabled ) + "concurrent_strategy": "*queue", // strategy in case in case of concurrent requests reached }, diff --git a/config/config_json_test.go b/config/config_json_test.go index 874198ecb..a673eaca2 100755 --- a/config/config_json_test.go +++ b/config/config_json_test.go @@ -62,6 +62,8 @@ func TestDfGeneralJsonCfg(t *testing.T) { Digest_equal: utils.StringPointer(":"), Rsr_separator: utils.StringPointer(";"), Max_parallel_conns: utils.IntPointer(100), + Concurrent_requests: utils.IntPointer(0), + Concurrent_strategy: utils.StringPointer(utils.MetaQueue), } if gCfg, err := dfCgrJSONCfg.GeneralJsonCfg(); err != nil { t.Error(err) diff --git a/data/conf/cgrates/cgrates.json b/data/conf/cgrates/cgrates.json index a423ec591..2a9ac6722 100755 --- a/data/conf/cgrates/cgrates.json +++ b/data/conf/cgrates/cgrates.json @@ -31,6 +31,8 @@ // "digest_equal": ":", // equal symbol used in case of digests // "rsr_separator": ";", // separator used within RSR fields // "max_parallel_conns": 100, // the maximum number of connection used by the *parallel strategy +// "concurrent_requests": 0, // maximum concurrent request allowed ( 0 to disabled ) +// "concurrent_strategy": "*queue", // strategy in case in case of concurrent requests reached // },