Hello,
As with your other thread, I suspect dmq_usrloc is at fault here. I've
not looked at this module before, but can take a look over the next
day or so if no one else gets to it first.
Cheers,
On 1 Jul 2015 22:13, "Asgaroth" <00asgarot...@gmail.com
<mailto:00asgarot...@gmail.com>> wrote:
Hi,
Sorry, the previous sample, was the incorrect timestamp, this one
is the corresponding message sent:
U 2015/07/01 20:40:52.446646 10.6.0.173:5060
<http://10.6.0.173:5060> -> 10.6.0.174:5060 <http://10.6.0.174:5060>
KDMQ sip:usrloc@10.6.0.174:5060
<mailto:sip:usrloc@10.6.0.174:5060> SIP/2.0.
Via: SIP/2.0/UDP
10.6.0.173;branch=z9hG4bK9b3c.fe993716000000000000000000000000.0.
To: <sip:usrloc@10.6.0.174:5060> <mailto:sip:usrloc@10.6.0.174:5060>.
From: <sip:usrloc@10.6.0.173:5060>
<mailto:sip:usrloc@10.6.0.173:5060>;tag=390c95c339281829d3cea6f43c8512cb-7e62.
CSeq: 10 KDMQ.
Call-ID: 3c502b38465e8d94-8433@10.6.0.173
<mailto:3c502b38465e8d94-8433@10.6.0.173>.
Content-Length: 471.
User-Agent: kamailio (bfievkrl01).
Max-Forwards: 1.
Content-Type: application/json.
.
{"action":1,"aor":"subscriber_name@subscriber_domain","ruid":"uloc-55941474-20f1-1","c":"sip:subscriber_name@212.2.160.202:61270;rinstance=7b7c543d11c12134;transport=UDP"
<mailto:sip:subscriber_name@212.2.160.202:61270;rinstance=7b7c543d11c12134;transport=UDP>,"received":"sip:212.2.160.202:61270
<http://212.2.160.202:61270>","path":"<sip:10.7.0.109;lr;received=sip:212.2.160.202:61270
<http://212.2.160.202:61270>>","callid":"rvOjXlyhAGK1aokNbR859w..","user_agent":"Z
3.7.30891
r30851","instance":"","expires":1435779765,"cseq":6,"flags":0,"cflags":64,"q":-1,"last_modified":1435779652,"methods":5087,"reg_id":0}
On 01/07/2015 21:30, Charles Chance wrote:
Hello,
Should be no need to load any additional deserializer. The docs
simply mean if you wish to send/receive your own messages from
within a module or script, it's up to you to choose the best
payload type and method of (de)serialization.
Can you post an example KDMQ message here to look at?
Cheers,
Charles
On 1 Jul 2015 20:49, "Asgaroth" <00asgarot...@gmail.com
<mailto:00asgarot...@gmail.com>> wrote:
Hi All,
I am playing with the new dmq_replicate module and am banging
my head against an issue I have come accross. I can see the
kamailio registrars sending the replication messages to the
other node(s) in the dmq bus, and the payload looks to be of
type json. However, on the recieving nodes, when I try to
issue a kamctl ul show --brief, the output of the AOR's are
garbled.
I had a look at the dmq/dmq_ursloc moduled, and the dmq
module docs mention that we may need to load our own
deserializers, is this the case when using the dmq_usrloc
module as well? I am only using dmq to replicate registration
messages.
Here is a sample of the dmq workers on a recieving node
applying the update, and you can see that it thinks the
contact to add is 'p÷#031#002', is was expecting the actual
AOR of the subriber to show up here.
Am I missing something simple here or is there something more
sinister at play.
Any pointers would be greatly appreciated.
Kamailio Version:
version: kamailio 4.3.0 (x86_64/linux) c6aa95
flags: STATS: Off, USE_TCP, USE_TLS, TLS_HOOKS,
USE_RAW_SOCKS, DISABLE_NAGLE, USE_MCAST, DNS_IP_HACK,
SHM_MEM, SHM_MMAP, PKG_MALLOC, F_MALLOC, DBG_F_MALLOC,
USE_FUTEX, FAST_LOCK-ADAPTIVE_WAIT, USE_DNS_CACHE,
USE_DNS_FAILOVER, USE_NAPTR, USE_DST_BLACKLIST, HAVE_RESOLV_RES
ADAPTIVE_WAIT_LOOPS=1024, MAX_RECV_BUFFER_SIZE 262144,
MAX_LISTEN 16, MAX_URI_SIZE 1024, BUF_SIZE 65535, DEFAULT
PKG_SIZE 8MB
poll method support: poll, epoll_lt, epoll_et, sigio_rt, select.
id: c6aa95
compiled on 16:14:27 Jun 23 2015 with gcc 4.4.7
Debug log below:
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:606]: parse_msg(): SIP Request:
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:608]: parse_msg(): method: <KDMQ>
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:610]: parse_msg(): uri:
<sip:usrloc@10.6.0.174:5060 <http://sip:usrloc@10.6.0.174:5060>>
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:612]: parse_msg(): version:
<SIP/2.0>
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/parse_via.c:1254]: parse_via_param(): Found
param type 232, <branch> =
<z9hG4bK9b3c.fe993716000000000000000000000000.0>; state=16
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/parse_via.c:2642]: parse_via(): end of header
reached, state=5
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:496]: parse_headers():
parse_headers: Via found, flags=2
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:498]: parse_headers():
parse_headers: this is the first via
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [receive.c:134]: receive_msg(): After parse_msg...
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [receive.c:177]: receive_msg(): preparing to run
routing scripts...
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
tm [t_lookup.c:1011]: t_check_msg(): DEBUG: t_check_msg: msg
id=450 global id=449 T start=0xffffffffffffffff
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/parse_addr_spec.c:894]: parse_addr_spec(): end
of header reached, state=10
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:173]: get_hdr_field(): DEBUG:
get_hdr_field: <To> [30]; uri=[sip:usrloc@10.6.0.174:5060
<mailto:sip:usrloc@10.6.0.174:5060>]
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:175]: get_hdr_field(): DEBUG: to
body [<sip:usrloc@10.6.0.174:5060
<http://sip:usrloc@10.6.0.174:5060>>#015#012]
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:153]: get_hdr_field():
get_hdr_field: cseq <CSeq>: <10> <KDMQ>
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:187]: get_hdr_field(): DEBUG:
get_hdr_body : content_length=471
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [parser/msg_parser.c:89]: get_hdr_field(): found end
of header
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
tm [t_lookup.c:466]: t_lookup_request(): t_lookup_request:
start searching: hash=50105, isACK=0
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
tm [t_lookup.c:424]: matching_3261(): DEBUG: RFC3261
transaction matching failed
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
tm [t_lookup.c:648]: t_lookup_request(): DEBUG:
t_lookup_request: no transaction found
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
tm [t_lookup.c:1080]: t_check_msg(): DEBUG: t_check_msg: msg
id=450 global id=450 T end=(nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
dmq [message.c:53]: dmq_handle_message(): dmq_handle_message
[KDMQ sip:usrloc@10.6.0.174:5060
<http://sip:usrloc@10.6.0.174:5060>] [ ]
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
dmq [message.c:65]: dmq_handle_message(): dmq_handle_message
peer found: usrloc
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq [worker.c:84]: worker_loop(): dmq_worker [0 23014] lock
acquired
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
<core> [parser/parse_addr_spec.c:172]: parse_to_param():
DEBUG: add_param: tag=390c95c339281829d3cea6f43c8512cb-7e62
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
<core> [parser/parse_addr_spec.c:894]: parse_addr_spec(): end
of header reached, state=29
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:250]: usrloc_dmq_handle_msg(): dmq
message received from sip:usrloc@10.6.0.173:5060
<http://sip:usrloc@10.6.0.173:5060>
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:353]: usrloc_dmq_handle_msg():
Received DMQ_UPDATE. Update contact info...
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:60]: add_contact(): 'p÷#031#002'
found in usrloc
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:62]: add_contact(): get_ucontact = 0
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:72]: add_contact(): Found contact
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
usrloc [ucontact.c:1688]: update_ucontact(): exists callback
for type= UL_CONTACT_UPDATE
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
usrloc [ul_callback.h:84]: run_ul_callbacks():
contact=0x7ffe86eabad8, callback type 2/15, id 0 entered
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:494]: dmq_ul_cb_contact(): Callback
from usrloc with type=2
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:517]: dmq_ul_cb_contact(): Contact
recieved from DMQ... skip
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:85]: add_contact(): Release record
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq_usrloc [usrloc_sync.c:87]: add_contact(): Unlock udomain
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
sl [sl.c:280]: send_reply(): reply in stateless mode (sl)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
<core> [msg_translator.c:158]: check_via_address():
(10.6.0.173, 10.6.0.173, 0)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [xavp.c:446]: xavp_destroy_list(): destroying xavp
list (nil)
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG:
<core> [receive.c:278]: receive_msg(): cleaning up
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq [worker.c:134]: worker_loop(): sent reply
Jul 1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG:
dmq [worker.c:82]: worker_loop(): dmq_worker [0 23014]
getting lock
_______________________________________________
SIP Express Router (SER) and Kamailio (OpenSER) - sr-users
mailing list
sr-users@lists.sip-router.org
<mailto:sr-users@lists.sip-router.org>
http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
www.sipcentric.com <http://www.sipcentric.com/>
Follow us on twitter @sipcentric <http://twitter.com/sipcentric>
Sipcentric Ltd. Company registered in England & Wales no.
7365592. Registered office: Faraday Wharf, Innovation Birmingham
Campus, Holt Street, Birmingham Science Park, Birmingham B7 4BB.
_______________________________________________
SIP Express Router (SER) and Kamailio (OpenSER) - sr-users mailing list
sr-users@lists.sip-router.org <mailto:sr-users@lists.sip-router.org>
http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
_______________________________________________
SIP Express Router (SER) and Kamailio (OpenSER) - sr-users mailing
list
sr-users@lists.sip-router.org <mailto:sr-users@lists.sip-router.org>
http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
www.sipcentric.com <http://www.sipcentric.com/>
Follow us on twitter @sipcentric <http://twitter.com/sipcentric>
Sipcentric Ltd. Company registered in England & Wales no. 7365592.
Registered office: Faraday Wharf, Innovation Birmingham Campus, Holt
Street, Birmingham Science Park, Birmingham B7 4BB.
_______________________________________________
SIP Express Router (SER) and Kamailio (OpenSER) - sr-users mailing list
sr-users@lists.sip-router.org
http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
