rabbitmq - TriggeredFunctionData null when entering Webjob SDK function -
i trying use rabbitmq extension webjob sdk (https://github.com/sarmaad/webjobs.extensions.rabbitmq) have trigger when put on queue.
the triggering works fine, content never passed function.
i downloaded source extension debug inside , see content of queue delivered , extension repackages triggeredfunctiondata object. object passed function through webjob executor. step function object null.
listener method extension lib:
_consumer.received += (sender, args) => { var triggervalue = new rabbitqueuetriggervalue {messagebytes = args.body}; if (args.basicproperties != null) { triggervalue.messageid = args.basicproperties.messageid; triggervalue.applicationid = args.basicproperties.appid; triggervalue.contenttype = args.basicproperties.contenttype; triggervalue.correlationid = args.basicproperties.correlationid; triggervalue.headers = args.basicproperties.headers; } var result = _executor.tryexecuteasync(new triggeredfunctiondata{triggervalue = triggervalue}, cancellationtoken.none).result; when debugging can see triggervalue contains message data.
my function being executed:
public static async task processrabbitmqtopicstatusmessage([rabbitqueuetrigger("tempq")] [rabbitqueuebinder("myexchange", "myroutingkey", "myerrorq",autodelete:true,durable:true, execlusive:false)] triggeredfunctiondata message, textwriter logger) { if (message != null) { } } this method triggered successfully, message null.
any suggestions?
Comments
Post a Comment