* */
| 428 | * |
| 429 | */ |
| 430 | str *get_mqk(str *in) |
| 431 | { |
| 432 | mq_pv_t *mp = NULL; |
| 433 | |
| 434 | if(mq_head_get(in) == NULL) { |
| 435 | LM_ERR("mqueue not found: %.*s\n", in->len, in->s); |
| 436 | return NULL; |
| 437 | } |
| 438 | |
| 439 | mp = mq_pv_get(in); |
| 440 | if(mp == NULL || mp->item == NULL || mp->item->key.len <= 0) |
| 441 | return NULL; |
| 442 | return &mp->item->key; |
| 443 | } |
| 444 | |
| 445 | /** |
| 446 | * |
no test coverage detected