mirror of https://github.com/celery/kombu.git
Fix reversed method references
According to docs on kombu.serialization.register the params order is (name, encoder, decoder, content_type, content_encoding). This caused us a bit of grief as I was too lazy to read the actual docs on register() :)
This commit is contained in:
parent
84eff17853
commit
8b68abfc40
|
@ -179,6 +179,6 @@ supported by Kombu.
|
||||||
def loads(s):
|
def loads(s):
|
||||||
return pickle.load(BytesIO(s))
|
return pickle.load(BytesIO(s))
|
||||||
|
|
||||||
register('my_pickle', loads, pickle.dumps,
|
register('my_pickle', pickle.dumps, loads,
|
||||||
content_type='application/x-pickle2',
|
content_type='application/x-pickle2',
|
||||||
content_encoding='binary')
|
content_encoding='binary')
|
||||||
|
|
Loading…
Reference in New Issue