Skip to content

Instantly share code, notes, and snippets.

@afterdesign
Created June 16, 2013 18:18
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save afterdesign/5792896 to your computer and use it in GitHub Desktop.
Save afterdesign/5792896 to your computer and use it in GitHub Desktop.
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);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment