single_body_task = {
"task" : "math.tasks.add",
"kwargs" : {
"a" : 1,
"b" : 2
},
"id" : sha1(json_encode(single_body_task['kwargs']))
}
task = {
"body" : base64_encode(json_encode(single_body_task)),
"headers" : [],
"content-type":"application\/json",
"properties": {
"body_encoding":"base64",
"delivery_info":{
"priority":0,
"routing_key":"celery",
"exchange":"mailer"
},
"delivery_mode":2,
"delivery_tag" : sha1(json_encode(task['body'])),
"content-encoding":"utf-8"
}
}
$redis->connect('127.0.0.1', 6379);
$redis->lPush('math', $task);