diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2013-07-17 12:45:09 +0200 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2013-07-17 12:45:09 +0200 |
| commit | 58b5616b41cd2cacf0b3039c8ebbd204d8918201 (patch) | |
| tree | 4cb6e76305b9ab3becd7cdee1b67589c3eb97b9e /runtime/msg.c | |
| parent | 4c2bef51d1517ad469e0ecf837ec7e87309ba1dd (diff) | |
| download | rsyslog-58b5616b41cd2cacf0b3039c8ebbd204d8918201.tar.gz rsyslog-58b5616b41cd2cacf0b3039c8ebbd204d8918201.tar.bz2 rsyslog-58b5616b41cd2cacf0b3039c8ebbd204d8918201.zip | |
make local vars work together with disk queues
Diffstat (limited to 'runtime/msg.c')
| -rw-r--r-- | runtime/msg.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/runtime/msg.c b/runtime/msg.c index e1c97188..58a74498 100644 --- a/runtime/msg.c +++ b/runtime/msg.c @@ -1216,6 +1216,14 @@ MsgDeserialize(msg_t *pMsg, strm_t *pStrm) reinitVar(pVar); CHKiRet(objDeserializeProperty(pVar, pStrm)); } + if(isProp("localvars")) { + tokener = json_tokener_new(); + pMsg->localvars = json_tokener_parse_ex(tokener, (char*)rsCStrGetSzStrNoNULL(pVar->val.pStr), + cstrLen(pVar->val.pStr)); + json_tokener_free(tokener); + reinitVar(pVar); + CHKiRet(objDeserializeProperty(pVar, pStrm)); + } if(isProp("pCSStrucData")) { MsgSetStructuredData(pMsg, (char*) rsCStrGetSzStrNoNULL(pVar->val.pStr)); reinitVar(pVar); |