diff options
| author | Joshua Colp <jcolp@digium.com> | 2016-06-09 16:45:54 -0500 |
|---|---|---|
| committer | Gerrit Code Review <gerrit2@gerrit.digium.api> | 2016-06-09 16:45:54 -0500 |
| commit | 914a1502fa95cc3d0db49a5855c271d9faff4614 (patch) | |
| tree | ccdc085e3bfbd260f06cc2d1662e523ac580e044 /main/stasis_message_router.c | |
| parent | 67a45e0a3887b225cbce9ec93f5f464e2865760d (diff) | |
| parent | dcfef53ee2339d09f839aa4e333419b80b309d8a (diff) | |
Merge "stasis: Add setting subscription congestion levels."
Diffstat (limited to 'main/stasis_message_router.c')
| -rw-r--r-- | main/stasis_message_router.c | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/main/stasis_message_router.c b/main/stasis_message_router.c index f60180d68..85034bcf9 100644 --- a/main/stasis_message_router.c +++ b/main/stasis_message_router.c @@ -289,6 +289,18 @@ void stasis_message_router_publish_sync(struct stasis_message_router *router, ao2_cleanup(router); } +int stasis_message_router_set_congestion_limits(struct stasis_message_router *router, + long low_water, long high_water) +{ + int res = -1; + + if (router) { + res = stasis_subscription_set_congestion_limits(router->subscription, + low_water, high_water); + } + return res; +} + int stasis_message_router_add(struct stasis_message_router *router, struct stasis_message_type *message_type, stasis_subscription_cb callback, void *data) |