'You must hook this up behind a Deserializer, so we expect the JSON
already dealt with.'

def deserialize(self, message):

    body = json.loads(message['text'])
    action = body['action']
    pk = body.get('pk', None)
    data = body.get('data', None)
    return (action, pk, data)
