Skip to content

Commit

Permalink
kazoo: fix kemi export due to changed function prototype
Browse files Browse the repository at this point in the history
- change done in dcb8e16
  • Loading branch information
miconda committed Dec 14, 2021
1 parent 2c23979 commit b0f4c83
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
9 changes: 7 additions & 2 deletions src/modules/kazoo/kz_amqp.c
Expand Up @@ -1262,10 +1262,10 @@ int kz_amqp_publish_ex(struct sip_msg* msg, char* exchange, char* routing_key, c
headers_s.s = "";
}

return ki_kz_amqp_publish(msg, &exchange_s, &routing_key_s, &pl_s, &headers_s);
return ki_kz_amqp_publish_hdrs(msg, &exchange_s, &routing_key_s, &pl_s, &headers_s);
};

int ki_kz_amqp_publish(sip_msg_t* msg, str* exchange, str* routing_key, str* payload, str* headers)
int ki_kz_amqp_publish_hdrs(sip_msg_t* msg, str* exchange, str* routing_key, str* payload, str* headers)
{
char *pl = ((str*)payload)->s;
struct json_object *j = json_tokener_parse(pl);
Expand All @@ -1279,6 +1279,11 @@ int ki_kz_amqp_publish(sip_msg_t* msg, str* exchange, str* routing_key, str* pay
return kz_amqp_pipe_send(exchange, routing_key, payload, headers);
}

int ki_kz_amqp_publish(sip_msg_t* msg, str* exchange, str* routing_key, str* payload)
{
return ki_kz_amqp_publish_hdrs(msg, exchange, routing_key, payload, NULL);
}

int kz_amqp_publish(struct sip_msg* msg, char* exchange, char* routing_key, char* payload)
{
return kz_amqp_publish_ex(msg, exchange, routing_key, payload, NULL);
Expand Down
1 change: 1 addition & 0 deletions src/modules/kazoo/kz_amqp.h
Expand Up @@ -276,6 +276,7 @@ int kz_amqp_add_connection(modparam_t type, void* val);
int kz_amqp_publish(struct sip_msg* msg, char* exchange, char* routing_key, char* payload);
int kz_amqp_publish_ex(struct sip_msg* msg, char* exchange, char* routing_key, char* payload, char* headers);
int ki_kz_amqp_publish(sip_msg_t* msg, str* exchange, str* routing_key, str* payload, str* headers);
int ki_kz_amqp_publish_hdrs(sip_msg_t* msg, str* exchange, str* routing_key, str* payload);
int kz_amqp_query(struct sip_msg* msg, char* exchange, char* routing_key, char* payload, char* dst, char* headers);
int kz_amqp_query_ex(struct sip_msg* msg, char* exchange, char* routing_key, char* payload, char* headers);
int kz_amqp_subscribe(struct sip_msg* msg, char* payload);
Expand Down

0 comments on commit b0f4c83

Please sign in to comment.