allow event consumer to supply size as optional arg
This commit is contained in:
parent
b472edf444
commit
830755ac85
|
@ -186,7 +186,7 @@ SWITCH_DECLARE(bool) email(char *to, char *from, char *headers = NULL, char *bod
|
|||
switch_event_node_t *enodes[SWITCH_EVENT_ALL + 1];
|
||||
uint32_t node_index;
|
||||
|
||||
SWITCH_DECLARE_CONSTRUCTOR EventConsumer(const char *event_name = NULL, const char *subclass_name = "");
|
||||
SWITCH_DECLARE_CONSTRUCTOR EventConsumer(const char *event_name = NULL, const char *subclass_name = "", int len = 5000);
|
||||
SWITCH_DECLARE_CONSTRUCTOR ~ EventConsumer();
|
||||
SWITCH_DECLARE(int) bind(const char *event_name, const char *subclass_name = "");
|
||||
SWITCH_DECLARE(Event *) pop(int block = 0, int timeout = 0);
|
||||
|
|
|
@ -50,11 +50,11 @@ static void event_handler(switch_event_t *event)
|
|||
|
||||
}
|
||||
|
||||
SWITCH_DECLARE_CONSTRUCTOR EventConsumer::EventConsumer(const char *event_name, const char *subclass_name)
|
||||
SWITCH_DECLARE_CONSTRUCTOR EventConsumer::EventConsumer(const char *event_name, const char *subclass_name, int len)
|
||||
{
|
||||
|
||||
switch_core_new_memory_pool(&pool);
|
||||
switch_queue_create(&events, 5000, pool);
|
||||
switch_queue_create(&events, len, pool);
|
||||
node_index = 0;
|
||||
|
||||
if (!zstr(event_name)) {
|
||||
|
|
Loading…
Reference in New Issue