x/stacktach
Code Issues Proposed changes

force message buffers to strings before decoding

Browse Source 
See Section "Buffer Objects:" in
http://kombu.readthedocs.org/en/latest/userguide/serialization.html

Conflicts:
	worker/worker.py
This commit is contained in:
Bernhard K. Weisshuhn 2014-02-06 00:47:30 +01:00
parent 7de5947d37
commit 7c47c360c3
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
worker/worker.py
View File

@ -19,6 +19,7 @@
import datetime
import sys
import time
import anyjson
import kombu
import kombu.mixins
@ -38,6 +39,7 @@ from stacktach import db
from stacktach import message_service
from stacktach import stacklog
from stacktach import views
from kombu.serialization import BytesIO, register
stacklog.set_default_logger_name('worker')
@ -61,6 +63,13 @@ class Consumer(kombu.mixins.ConsumerMixin):
self.topics = topics
self.exchange = exchange
register('bufferjson', self.loads, anyjson.dumps,
content_type='application/json',
content_encoding='binary')
def loads(s):
return anyjson.loads(BytesIO(s))
def _create_exchange(self, name, type, exclusive=False, auto_delete=False):
return message_service.create_exchange(name, exchange_type=type,
exclusive=exclusive,